org.apache.drill.exec.physical.config

Class MetadataStreamAggPOP

java.lang.Object

org.apache.drill.exec.physical.base.AbstractBase

org.apache.drill.exec.physical.base.AbstractSingle

org.apache.drill.exec.physical.config.StreamingAggregate

org.apache.drill.exec.physical.config.MetadataStreamAggPOP

All Implemented Interfaces:

Iterable<PhysicalOperator>, GraphValue<PhysicalOperator>, PhysicalOperator

public class MetadataStreamAggPOP
extends StreamingAggregate

Field Summary

Fields inherited from class org.apache.drill.exec.physical.config.StreamingAggregate

OPERATOR_TYPE

Fields inherited from class org.apache.drill.exec.physical.base.AbstractSingle

child

Fields inherited from class org.apache.drill.exec.physical.base.AbstractBase

INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation

Constructor Summary

Constructors

Constructor and Description
MetadataStreamAggPOP(PhysicalOperator child, MetadataAggregateContext context, AggPrelBase.OperatorPhase phase)

Method Summary

Modifier and Type	Method and Description
MetadataAggregateContext	getContext()
protected PhysicalOperator	getNewWithChild(PhysicalOperator child)
AggPrelBase.OperatorPhase	getPhase()

Methods inherited from class org.apache.drill.exec.physical.config.StreamingAggregate

accept, getExprs, getKeys, getOperatorType

Methods inherited from class org.apache.drill.exec.physical.base.AbstractSingle

getChild, getNewWithChildren, iterator

Methods inherited from class org.apache.drill.exec.physical.base.AbstractBase

accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

MetadataStreamAggPOP

public MetadataStreamAggPOP(PhysicalOperator child,
                            MetadataAggregateContext context,
                            AggPrelBase.OperatorPhase phase)

Method Detail

getNewWithChild

protected PhysicalOperator getNewWithChild(PhysicalOperator child)

Overrides:

getNewWithChild in class StreamingAggregate

getContext

public MetadataAggregateContext getContext()

getPhase

public AggPrelBase.OperatorPhase getPhase()