org.apache.drill.exec.store.mapr.db

Class MapRDBGroupScan

java.lang.Object

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

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

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

org.apache.drill.exec.store.mapr.db.MapRDBGroupScan

All Implemented Interfaces:

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

Direct Known Subclasses:

BinaryTableGroupScan, JsonTableGroupScan

public abstract class MapRDBGroupScan
extends AbstractDbGroupScan

Field Summary

Fields

Modifier and Type	Field and Description
protected List<SchemaPath>	columns
protected double	costFactor
protected NavigableMap<TabletFragmentInfo,String>	doNotAccessRegionsToScan
protected Map<Integer,List<MapRDBSubScanSpec>>	endpointFragmentMapping
protected MapRDBFormatPlugin	formatPlugin
protected MapRDBFormatPluginConfig	formatPluginConfig
protected AbstractStoragePlugin	storagePlugin

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
MapRDBGroupScan(AbstractStoragePlugin storagePlugin, MapRDBFormatPlugin formatPlugin, List<SchemaPath> columns, String userName, TableMetadataProvider metadataProvider)
MapRDBGroupScan(MapRDBGroupScan that)

Method Summary

Modifier and Type	Method and Description
void	applyAssignments(List<CoordinationProtos.DrillbitEndpoint> incomingEndpoints)
boolean	canPushdownProjects(List<SchemaPath> columns) GroupScan should check the list of columns, and see if it could support all the columns in the list.
List<SchemaPath>	getColumns() Returns a list of columns scanned by this group scan
String	getDigest() Returns a signature of the GroupScan which should usually be composed of all its attributes which could describe it uniquely.
MapRDBFormatPlugin	getFormatPlugin()
String	getIndexHint()
int	getMaxParallelizationWidth()
TableMetadataProvider	getMetadataProvider() Returns TableMetadataProvider instance which is used for providing metadata for current GroupScan.
List<EndpointAffinity>	getOperatorAffinity() Get the list of Endpoints with associated affinities that this operator has preference for.
PluginCost	getPluginCostModel() Get the format plugin cost model.
protected NavigableMap<TabletFragmentInfo,String>	getRegionsToScan()
int	getRowKeyOrdinal()
TupleMetadata	getSchema()
IndexCollection	getSecondaryIndexCollection(org.apache.calcite.rel.RelNode scanRel) Get the index collection associated with this table if any
StoragePluginConfig	getStorageConfig()
AbstractStoragePlugin	getStoragePlugin()
protected abstract MapRDBSubScanSpec	getSubScanSpec(TabletFragmentInfo key)
TableMetadata	getTableMetadata()
abstract String	getTableName()
boolean	isFilterPushedDown()
protected void	resetRegionsToScan()
void	setCostFactor(double sel)
void	setFilterPushedDown(boolean b)
protected void	setRegionsToScan(NavigableMap<TabletFragmentInfo,String> regionsToScan)

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

getRangePartitionFunction, getRestrictedScan, getRowKeyName, getRowKeyPath, isRestrictedScan, supportsRestrictedScan, supportsSecondaryIndex

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

accept, applyFilter, applyLimit, clone, enforceWidth, getAnalyzeInfoProvider, getColumnValueCount, getDistributionAffinity, getFiles, getFilter, getInitialAllocation, getMaxAllocation, getMinParallelizationWidth, getOperatorType, getPartitionColumns, getScanStats, getScanStats, getScanStats, getSelectionRoot, 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

getRowCount, getStatistics, isIndexScan, setRowCount

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

applyFilter, applyLimit, clone, enforceWidth, getAnalyzeInfoProvider, getColumnValueCount, getFiles, getFilter, getMinParallelizationWidth, getPartitionColumns, getScanStats, getScanStats, getSelectionRoot, getSpecificScan, 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

Field Detail

storagePlugin

protected AbstractStoragePlugin storagePlugin

formatPlugin

protected MapRDBFormatPlugin formatPlugin

formatPluginConfig

protected MapRDBFormatPluginConfig formatPluginConfig

columns

protected List<SchemaPath> columns

endpointFragmentMapping

protected Map<Integer,List<MapRDBSubScanSpec>> endpointFragmentMapping

doNotAccessRegionsToScan

protected NavigableMap<TabletFragmentInfo,String> doNotAccessRegionsToScan

costFactor

protected double costFactor

Constructor Detail

MapRDBGroupScan

public MapRDBGroupScan(MapRDBGroupScan that)

MapRDBGroupScan

public MapRDBGroupScan(AbstractStoragePlugin storagePlugin,
                       MapRDBFormatPlugin formatPlugin,
                       List<SchemaPath> columns,
                       String userName,
                       TableMetadataProvider metadataProvider)

Method Detail

getOperatorAffinity

public List<EndpointAffinity> getOperatorAffinity()

Description copied from interface: HasAffinity

Get the list of Endpoints with associated affinities that this operator has preference for.

Specified by:

getOperatorAffinity in interface HasAffinity

Overrides:

getOperatorAffinity in class AbstractGroupScan

Returns:

List of EndpointAffinity objects.

applyAssignments

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

Parameters:

incomingEndpoints -

getMaxParallelizationWidth

public int getMaxParallelizationWidth()

getFormatPlugin

public MapRDBFormatPlugin getFormatPlugin()

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.

getStorageConfig

public StoragePluginConfig getStorageConfig()

Specified by:

getStorageConfig in class AbstractDbGroupScan

getStoragePlugin

public AbstractStoragePlugin getStoragePlugin()

Specified by:

getStoragePlugin in class AbstractDbGroupScan

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 DbGroupScan

Specified by:

getColumns in interface GroupScan

Overrides:

getColumns in class AbstractGroupScan

canPushdownProjects

public boolean canPushdownProjects(List<SchemaPath> columns)

Description copied from interface: GroupScan

GroupScan should check the list of columns, and see if it could support all the columns in the list.

Specified by:

canPushdownProjects in interface GroupScan

Overrides:

canPushdownProjects in class AbstractGroupScan

setFilterPushedDown

public void setFilterPushedDown(boolean b)

getIndexHint

public String getIndexHint()

isFilterPushedDown

public boolean isFilterPushedDown()

getSubScanSpec

protected abstract MapRDBSubScanSpec getSubScanSpec(TabletFragmentInfo key)

setCostFactor

public void setCostFactor(double sel)

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

Overrides:

getSecondaryIndexCollection in class AbstractDbGroupScan

getTableName

public abstract String getTableName()

getRowKeyOrdinal

public int getRowKeyOrdinal()

getRegionsToScan

protected NavigableMap<TabletFragmentInfo,String> getRegionsToScan()

resetRegionsToScan

protected void resetRegionsToScan()

setRegionsToScan

protected void setRegionsToScan(NavigableMap<TabletFragmentInfo,String> regionsToScan)

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

Overrides:

getPluginCostModel in class AbstractDbGroupScan

Returns:

a PluginCost cost model

getSchema

public TupleMetadata getSchema()

getMetadataProvider

public TableMetadataProvider getMetadataProvider()

Description copied from interface: GroupScan

Returns TableMetadataProvider instance which is used for providing metadata for current GroupScan.

Specified by:

getMetadataProvider in interface GroupScan

Overrides:

getMetadataProvider in class AbstractGroupScan

Returns:

TableMetadataProvider instance the source of metadata

getTableMetadata

public TableMetadata getTableMetadata()

Specified by:

getTableMetadata in interface GroupScan

Overrides:

getTableMetadata in class AbstractGroupScan