org.apache.drill.exec.physical.base

Class AbstractDbGroupScan

java.lang.Object

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

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

org.apache.drill.exec.physical.base.AbstractDbGroupScan

All Implemented Interfaces:

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

Direct Known Subclasses:

MapRDBGroupScan

public abstract class AbstractDbGroupScan
extends AbstractGroupScan
implements DbGroupScan

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 and Description
AbstractDbGroupScan(AbstractDbGroupScan that)
AbstractDbGroupScan(String userName)

Method Summary

Modifier and Type	Method and Description
PluginCost	getPluginCostModel() Get the format plugin cost model.
PartitionFunction	getRangePartitionFunction(List<FieldReference> refList) Get a partition function instance for range based partitioning
DbGroupScan	getRestrictedScan(List<SchemaPath> columns) If this DbGroupScan supports restricted scan, create a restricted scan from this DbGroupScan.
String	getRowKeyName()
SchemaPath	getRowKeyPath()
IndexCollection	getSecondaryIndexCollection(org.apache.calcite.rel.RelNode scanrel) Get the index collection associated with this table if any
abstract StoragePluginConfig	getStorageConfig()
abstract AbstractStoragePlugin	getStoragePlugin()
boolean	isRestrictedScan() Whether this DbGroupScan is itself a restricted scan
boolean	supportsRestrictedScan() Whether this DbGroupScan supports creating a restricted (skip) scan
boolean	supportsSecondaryIndex()

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

accept, applyFilter, applyLimit, canPushdownProjects, clone, enforceWidth, getAnalyzeInfoProvider, getColumns, getColumnValueCount, getDistributionAffinity, getFiles, getFilter, getInitialAllocation, getMaxAllocation, getMetadataProvider, getMinParallelizationWidth, getOperatorAffinity, getOperatorType, getPartitionColumns, getScanStats, 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, toString, wait, wait, wait

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

getColumns, getIndexHint, getRowCount, getStatistics, isFilterPushedDown, isIndexScan, setCostFactor, setRowCount

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

applyAssignments, applyFilter, applyLimit, canPushdownProjects, clone, enforceWidth, getAnalyzeInfoProvider, getColumnValueCount, getDigest, getFiles, getFilter, getMaxParallelizationWidth, getMetadataProvider, getMinParallelizationWidth, getPartitionColumns, getScanStats, getScanStats, getSelectionRoot, getSpecificScan, getTableMetadata, hasFiles, isDistributed, supportsFilterPushDown, supportsLimitPushdown, supportsPartitionFilterPushdown, usedMetastore

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

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

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

accept

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

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

getDistributionAffinity, getOperatorAffinity

Constructor Detail

AbstractDbGroupScan

public AbstractDbGroupScan(String userName)

AbstractDbGroupScan

public AbstractDbGroupScan(AbstractDbGroupScan that)

Method Detail

getStoragePlugin

public abstract AbstractStoragePlugin getStoragePlugin()

getStorageConfig

public abstract StoragePluginConfig getStorageConfig()

supportsSecondaryIndex

public boolean supportsSecondaryIndex()

Specified by:

supportsSecondaryIndex in interface DbGroupScan

getSecondaryIndexCollection

public IndexCollection getSecondaryIndexCollection(org.apache.calcite.rel.RelNode scanrel)

Description copied from interface: DbGroupScan

Get the index collection associated with this table if any

Specified by:

getSecondaryIndexCollection in interface DbGroupScan

supportsRestrictedScan

public boolean supportsRestrictedScan()

Description copied from interface: DbGroupScan

Whether this DbGroupScan supports creating a restricted (skip) scan

Specified by:

supportsRestrictedScan in interface DbGroupScan

Returns:

true if restricted scan is supported, false otherwise

isRestrictedScan

public boolean isRestrictedScan()

Description copied from interface: DbGroupScan

Whether this DbGroupScan is itself a restricted scan

Specified by:

isRestrictedScan in interface DbGroupScan

Returns:

true if this DbGroupScan is itself a restricted scan, false otherwise

getRestrictedScan

public DbGroupScan getRestrictedScan(List<SchemaPath> columns)

Description copied from interface: DbGroupScan

If this DbGroupScan supports restricted scan, create a restricted scan from this DbGroupScan.

Specified by:

getRestrictedScan in interface DbGroupScan

Parameters:

columns - list of column paths

Returns:

a non-null DbGroupScan if restricted scan is supported, null otherwise

getRowKeyName

public String getRowKeyName()

Specified by:

getRowKeyName in interface DbGroupScan

getRowKeyPath

public SchemaPath getRowKeyPath()

Specified by:

getRowKeyPath in interface DbGroupScan

getRangePartitionFunction

public PartitionFunction getRangePartitionFunction(List<FieldReference> refList)

Description copied from interface: DbGroupScan

Get a partition function instance for range based partitioning

Specified by:

getRangePartitionFunction in interface DbGroupScan

Parameters:

refList - a list of FieldReference exprs that are participating in the range partitioning

Returns:

instance of a partitioning function

getPluginCostModel

public PluginCost getPluginCostModel()

Description copied from interface: DbGroupScan

Get the format plugin cost model. The cost model will provide cost factors such as seq. scan cost, random scan cost, block size

Specified by:

getPluginCostModel in interface DbGroupScan

Returns:

a PluginCost cost model