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

Class BinaryTableGroupScan

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

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

All Implemented Interfaces:

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

public class BinaryTableGroupScan
extends MapRDBGroupScan
implements DrillHBaseConstants

Field Summary

Fields

Modifier and Type	Field and Description
static String	TABLE_BINARY

Fields inherited from class org.apache.drill.exec.store.mapr.db.MapRDBGroupScan

columns, costFactor, doNotAccessRegionsToScan, endpointFragmentMapping, formatPlugin, formatPluginConfig, 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.store.hbase.DrillHBaseConstants

COLUMN_FAMILY_TYPE, COLUMN_TYPE, HBASE_ZOOKEEPER_PORT, ROW_KEY, ROW_KEY_PATH, ROW_KEY_TYPE, SYS_STORE_PROVIDER_HBASE_CONFIG, SYS_STORE_PROVIDER_HBASE_TABLE

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

ALL_COLUMNS

Constructor Summary

Constructors

Constructor and Description
BinaryTableGroupScan(String userName, AbstractStoragePlugin storagePlugin, MapRDBFormatPlugin formatPlugin, HBaseScanSpec scanSpec, List<SchemaPath> columns, MapRDBTableStats tableStats, TableMetadataProvider metadataProvider)
BinaryTableGroupScan(String userName, AbstractStoragePlugin storagePlugin, MapRDBFormatPlugin formatPlugin, HBaseScanSpec scanSpec, List<SchemaPath> columns, MetadataProviderManager metadataProviderManager)
BinaryTableGroupScan(String userName, HBaseScanSpec scanSpec, FileSystemConfig storagePluginConfig, MapRDBFormatPluginConfig formatPluginConfig, List<SchemaPath> columns, TupleMetadata schema, StoragePluginRegistry pluginRegistry)

Method Summary

Modifier and Type	Method and Description
GroupScan	clone(List<SchemaPath> columns) Returns a clone of GroupScan instance, except that the new GroupScan will use the provided list of columns .
org.apache.hadoop.conf.Configuration	getHBaseConf()
HBaseScanSpec	getHBaseScanSpec()
PhysicalOperator	getNewWithChildren(List<PhysicalOperator> children) Regenerate with this node with a new set of children.
double	getRowCount(org.apache.calcite.rex.RexNode condition, org.apache.calcite.rel.RelNode scanRel) Get the row count after applying the RexNode condition
ScanStats	getScanStats()
MapRDBSubScan	getSpecificScan(int minorFragmentId)
Statistics	getStatistics() Get the statistics for this DbGroupScan
protected MapRDBSubScanSpec	getSubScanSpec(TabletFragmentInfo tfi)
String	getTableName()
MapRDBTableStats	getTableStats()
boolean	isIndexScan()
void	setRowCount(org.apache.calcite.rex.RexNode condition, double count, double capRowCount) Set the artificial row count after applying the RexNode condition
String	toString()

Methods inherited from class org.apache.drill.exec.store.mapr.db.MapRDBGroupScan

applyAssignments, canPushdownProjects, getColumns, getDigest, getFormatPlugin, getIndexHint, getMaxParallelizationWidth, getMetadataProvider, getOperatorAffinity, getPluginCostModel, getRegionsToScan, getRowKeyOrdinal, getSchema, getSecondaryIndexCollection, getStorageConfig, getStoragePlugin, getTableMetadata, isFilterPushedDown, resetRegionsToScan, setCostFactor, setFilterPushedDown, setRegionsToScan

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, enforceWidth, getAnalyzeInfoProvider, getColumnValueCount, getDistributionAffinity, getFiles, getFilter, getInitialAllocation, getMaxAllocation, getMinParallelizationWidth, getOperatorType, getPartitionColumns, 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, wait, wait, wait

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

applyFilter, applyLimit, enforceWidth, getAnalyzeInfoProvider, getColumnValueCount, getFiles, getFilter, getMinParallelizationWidth, getPartitionColumns, getScanStats, getScanStats, getSelectionRoot, hasFiles, isDistributed, supportsFilterPushDown, supportsLimitPushdown, supportsPartitionFilterPushdown, usedMetastore

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

accept, getCost, getInitialAllocation, getMaxAllocation, 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

TABLE_BINARY

public static final String TABLE_BINARY

See Also:

Constant Field Values

Constructor Detail

BinaryTableGroupScan

public BinaryTableGroupScan(String userName,
                            HBaseScanSpec scanSpec,
                            FileSystemConfig storagePluginConfig,
                            MapRDBFormatPluginConfig formatPluginConfig,
                            List<SchemaPath> columns,
                            TupleMetadata schema,
                            StoragePluginRegistry pluginRegistry)
                     throws ExecutionSetupException

Throws:

ExecutionSetupException

BinaryTableGroupScan

public BinaryTableGroupScan(String userName,
                            AbstractStoragePlugin storagePlugin,
                            MapRDBFormatPlugin formatPlugin,
                            HBaseScanSpec scanSpec,
                            List<SchemaPath> columns,
                            MetadataProviderManager metadataProviderManager)

BinaryTableGroupScan

public BinaryTableGroupScan(String userName,
                            AbstractStoragePlugin storagePlugin,
                            MapRDBFormatPlugin formatPlugin,
                            HBaseScanSpec scanSpec,
                            List<SchemaPath> columns,
                            MapRDBTableStats tableStats,
                            TableMetadataProvider metadataProvider)

Method Detail

clone

public GroupScan clone(List<SchemaPath> columns)

Description copied from interface: GroupScan

Returns a clone of GroupScan instance, except that the new GroupScan will use the provided list of columns .

Specified by:

clone in interface GroupScan

Overrides:

clone in class AbstractGroupScan

getSubScanSpec

protected MapRDBSubScanSpec getSubScanSpec(TabletFragmentInfo tfi)

Specified by:

getSubScanSpec in class MapRDBGroupScan

getSpecificScan

public MapRDBSubScan getSpecificScan(int minorFragmentId)

Specified by:

getSpecificScan in interface GroupScan

getScanStats

public ScanStats getScanStats()

Overrides:

getScanStats in class AbstractGroupScan

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.

Specified by:

getNewWithChildren in interface PhysicalOperator

getHBaseConf

public org.apache.hadoop.conf.Configuration getHBaseConf()

getTableName

public String getTableName()

Specified by:

getTableName in class MapRDBGroupScan

getTableStats

public MapRDBTableStats getTableStats()

toString

public String toString()

Overrides:

toString in class Object

getHBaseScanSpec

public HBaseScanSpec getHBaseScanSpec()

setRowCount

public void setRowCount(org.apache.calcite.rex.RexNode condition,
                        double count,
                        double capRowCount)

Description copied from interface: DbGroupScan

Set the artificial row count after applying the RexNode condition

Specified by:

setRowCount in interface DbGroupScan

Parameters:

condition - row expression

count - right index row count

capRowCount - row count limit

getRowCount

public double getRowCount(org.apache.calcite.rex.RexNode condition,
                          org.apache.calcite.rel.RelNode scanRel)

Description copied from interface: DbGroupScan

Get the row count after applying the RexNode condition

Specified by:

getRowCount in interface DbGroupScan

Parameters:

condition - filter to apply

scanRel - the current scan rel

Returns:

row count post filtering

getStatistics

public Statistics getStatistics()

Description copied from interface: DbGroupScan

Get the statistics for this DbGroupScan

Specified by:

getStatistics in interface DbGroupScan

Returns:

the Statistics for this Scan

isIndexScan

public boolean isIndexScan()

Specified by:

isIndexScan in interface DbGroupScan