Package org.apache.drill.exec.store.enumerable

Class EnumerableGroupScan

java.lang.Object

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

org.apache.drill.exec.physical.base.AbstractGroupScan

org.apache.drill.exec.store.enumerable.EnumerableGroupScan

All Implemented Interfaces:

Iterable<PhysicalOperator>, GraphValue<PhysicalOperator>, FragmentLeaf, GroupScan, HasAffinity, Leaf, PhysicalOperator, Scan

public class EnumerableGroupScan
extends AbstractGroupScan

Field Summary

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

INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName

Fields inherited from interface org.apache.drill.exec.physical.base.GroupScan

ALL_COLUMNS

Constructor Summary

Constructors

Constructor	Description
EnumerableGroupScan(String code, List<SchemaPath> columns, Map<String,Integer> fieldsMap, double rows, TupleMetadata schema, String schemaPath, ColumnConverterFactoryProvider converterFactoryProvider)

Method Summary

Modifier and Type	Method	Description
void	applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)
String	getCode()
List<SchemaPath>	getColumns()	Returns a list of columns scanned by this group scan
ColumnConverterFactoryProvider	getConverterFactoryProvider()
String	getDigest()	Returns a signature of the GroupScan which should usually be composed of all its attributes which could describe it uniquely.
Map<String,Integer>	getFieldsMap()
int	getMaxParallelizationWidth()
PhysicalOperator	getNewWithChildren(List<PhysicalOperator> children)	Regenerate with this node with a new set of children.
double	getRows()
ScanStats	getScanStats()
TupleMetadata	getSchema()
String	getSchemaPath()
SubScan	getSpecificScan(int minorFragmentId)
String	toString()

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

accept, applyFilter, applyLimit, canPushdownProjects, clone, enforceWidth, getAnalyzeInfoProvider, getColumnValueCount, getDistributionAffinity, getFiles, getFilter, getInitialAllocation, getMaxAllocation, getMetadataProvider, getMinParallelizationWidth, getOperatorAffinity, getOperatorType, getPartitionColumns, getScanStats, getScanStats, getSelectionRoot, getTableMetadata, hasFiles, isDistributed, isExecutable, iterator, supportsFilterPushDown, supportsLimitPushdown, supportsPartitionFilterPushdown, usedMetastore

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

accept, getCost, getOperatorId, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.common.graph.GraphValue

accept

Methods inherited from interface java.lang.Iterable

forEach, spliterator

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

getCost, getOperatorId, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId

Constructor Details

EnumerableGroupScan

public EnumerableGroupScan(String code,
 List<SchemaPath> columns,
 Map<String,Integer> fieldsMap,
 double rows,
 TupleMetadata schema,
 String schemaPath,
 ColumnConverterFactoryProvider converterFactoryProvider)

Method Details

applyAssignments

public void applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)

getSpecificScan

public SubScan getSpecificScan(int minorFragmentId)

getMaxParallelizationWidth

public int getMaxParallelizationWidth()

getScanStats

public ScanStats getScanStats()

Overrides:

getScanStats in class AbstractGroupScan

getCode

public String getCode()

getColumns

public List<SchemaPath> getColumns()

Description copied from interface: GroupScan

Returns a list of columns scanned by this group scan

Specified by:

getColumns in interface GroupScan

Overrides:

getColumns in class AbstractGroupScan

getFieldsMap

public Map<String,Integer> getFieldsMap()

getRows

public double getRows()

getSchema

public TupleMetadata getSchema()

getSchemaPath

public String getSchemaPath()

getConverterFactoryProvider

public ColumnConverterFactoryProvider getConverterFactoryProvider()

getDigest

public String getDigest()

Description copied from interface: GroupScan

Returns a signature of the GroupScan which should usually be composed of all its attributes which could describe it uniquely.

getNewWithChildren

public PhysicalOperator getNewWithChildren(List<PhysicalOperator> children)

Description copied from interface: PhysicalOperator

Regenerate with this node with a new set of children. This is used in the case of materialization or optimization.

Parameters:

children -

toString

public String toString()

Overrides:

toString in class Object