public class StatisticsAggregate extends StreamingAggregate
Modifier and Type | Field and Description |
---|---|
static String |
OPERATOR_TYPE |
child
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
Constructor and Description |
---|
StatisticsAggregate(PhysicalOperator child,
List<String> functions) |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value)
Provides capability to build a set of output based on traversing a query graph tree.
|
List<String> |
getFunctions() |
protected PhysicalOperator |
getNewWithChild(PhysicalOperator child) |
String |
getOperatorType() |
getExprs, getKeys
getChild, getNewWithChildren, iterator
accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public static final String OPERATOR_TYPE
public StatisticsAggregate(PhysicalOperator child, List<String> functions)
public <T,X,E extends Throwable> T accept(PhysicalVisitor<T,X,E> physicalVisitor, X value) throws E extends Throwable
PhysicalOperator
accept
in interface PhysicalOperator
accept
in class StreamingAggregate
E extends Throwable
protected PhysicalOperator getNewWithChild(PhysicalOperator child)
getNewWithChild
in class StreamingAggregate
public String getOperatorType()
getOperatorType
in interface PhysicalOperator
getOperatorType
in class StreamingAggregate
Copyright © 1970 The Apache Software Foundation. All rights reserved.