org.apache.drill.exec.physical.base

Class AbstractBase

java.lang.Object

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

All Implemented Interfaces:

Iterable<PhysicalOperator>, GraphValue<PhysicalOperator>, PhysicalOperator

Direct Known Subclasses:

AbstractGroupScan, AbstractJoinPop, AbstractMultiple, AbstractParquetRowGroupScan, AbstractReceiver, AbstractSingle, AbstractSubScan, DruidSubScan, HBaseSubScan, HiveSubScan, HttpSubScan, IcebergSubScan, KafkaSubScan, KuduSubScan, MetadataControllerPOP, MockSubScanPOP, MongoSubScan, OpenTSDBSubScan, PhoenixSubScan, RowKeyJoinPOP, SplunkSubScan, UnnestPOP, Values

public abstract class AbstractBase
extends Object
implements PhysicalOperator

Field Summary

Fields

Modifier and Type	Field and Description
static long	INIT_ALLOCATION
protected long	initialAllocation
static long	MAX_ALLOCATION
protected long	maxAllocation
protected String	userName

Constructor Summary

Constructors

Constructor and Description
AbstractBase()
AbstractBase(AbstractBase that)
AbstractBase(String userName)

Method Summary

Modifier and Type	Method and Description
void	accept(GraphVisitor<PhysicalOperator> visitor)
PrelCostEstimates	getCost()
long	getInitialAllocation()
long	getMaxAllocation()
int	getOperatorId()
BatchSchema.SelectionVectorMode	getSVMode() Describes the SelectionVector Mode for the output steam from this physical op.
String	getUserName() Name of the user whom to impersonate while setting up the implementation (RecordBatch) of this PhysicalOperator.
boolean	isBufferedOperator(QueryContext queryContext) Any operator that supports spilling should override this method (and return true)
boolean	isExecutable() Describes whether or not a particular physical operator can actually be executed.
void	setCost(PrelCostEstimates cost)
void	setMaxAllocation(long maxAllocation) Any operator that supports spilling should override this method
void	setOperatorId(int id)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.physical.base.PhysicalOperator

accept, getNewWithChildren, getOperatorType

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Field Detail

INIT_ALLOCATION

public static long INIT_ALLOCATION

MAX_ALLOCATION

public static long MAX_ALLOCATION

initialAllocation

protected long initialAllocation

maxAllocation

protected long maxAllocation

userName

protected final String userName

Constructor Detail

AbstractBase

public AbstractBase()

AbstractBase

public AbstractBase(String userName)

AbstractBase

public AbstractBase(AbstractBase that)

Method Detail

accept

public void accept(GraphVisitor<PhysicalOperator> visitor)

Specified by:

accept in interface GraphValue<PhysicalOperator>

isExecutable

public boolean isExecutable()

Description copied from interface: PhysicalOperator

Describes whether or not a particular physical operator can actually be executed. Most physical operators can be executed. However, Exchange nodes cannot be executed. In order to be executed, they must be converted into their Exec sub components.

Specified by:

isExecutable in interface PhysicalOperator

setOperatorId

public final void setOperatorId(int id)

Specified by:

setOperatorId in interface PhysicalOperator

getOperatorId

public int getOperatorId()

Specified by:

getOperatorId in interface PhysicalOperator

getSVMode

public BatchSchema.SelectionVectorMode getSVMode()

Description copied from interface: PhysicalOperator

Describes the SelectionVector Mode for the output steam from this physical op. This property is used during physical plan creating using PhysicalPlanCreator.

Specified by:

getSVMode in interface PhysicalOperator

getInitialAllocation

public long getInitialAllocation()

Specified by:

getInitialAllocation in interface PhysicalOperator

Returns:

The memory to preallocate for this operator

getCost

public PrelCostEstimates getCost()

Specified by:

getCost in interface PhysicalOperator

setCost

public void setCost(PrelCostEstimates cost)

Specified by:

setCost in interface PhysicalOperator

getMaxAllocation

public long getMaxAllocation()

Specified by:

getMaxAllocation in interface PhysicalOperator

Returns:

The maximum memory this operator can allocate

setMaxAllocation

public void setMaxAllocation(long maxAllocation)

Any operator that supports spilling should override this method

Specified by:

setMaxAllocation in interface PhysicalOperator

Parameters:

maxAllocation - The max memory allocation to be set

isBufferedOperator

public boolean isBufferedOperator(QueryContext queryContext)

Any operator that supports spilling should override this method (and return true)

Specified by:

isBufferedOperator in interface PhysicalOperator

Parameters:

queryContext -

Returns:

false

getUserName

public String getUserName()

Description copied from interface: PhysicalOperator

Name of the user whom to impersonate while setting up the implementation (RecordBatch) of this PhysicalOperator. Default value is "null" in which case we impersonate as user who launched the query.

Specified by:

getUserName in interface PhysicalOperator