Package org.apache.drill.exec.store.hbase

Class HBaseGroupScan

java.lang.Object

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

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

org.apache.drill.exec.store.hbase.HBaseGroupScan

All Implemented Interfaces:

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

public class HBaseGroupScan
extends AbstractGroupScan
implements DrillHBaseConstants

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.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	Description
HBaseGroupScan()	Empty constructor, do not use, only for testing.
HBaseGroupScan(String userName, HBaseScanSpec hbaseScanSpec, HBaseStoragePluginConfig storagePluginConfig, List<SchemaPath> columns, StoragePluginRegistry pluginRegistry)
HBaseGroupScan(String userName, HBaseStoragePlugin storagePlugin, HBaseScanSpec scanSpec, List<SchemaPath> columns)

Method Summary

Modifier and Type	Method	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.
GroupScan	clone(List<SchemaPath> columns)	Returns a clone of GroupScan instance, except that the new GroupScan will use the provided list of columns .
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.
org.apache.hadoop.conf.Configuration	getHBaseConf()
HBaseScanSpec	getHBaseScanSpec()
int	getMaxParallelizationWidth()
PhysicalOperator	getNewWithChildren(List<PhysicalOperator> children)	Regenerate with this node with a new set of children.
List<EndpointAffinity>	getOperatorAffinity()	Get the list of Endpoints with associated affinities that this operator has preference for.
ScanStats	getScanStats()
HBaseSubScan	getSpecificScan(int minorFragmentId)
HBaseStoragePluginConfig	getStorageConfig()
HBaseStoragePlugin	getStoragePlugin()
String	getTableName()
boolean	isFilterPushedDown()
void	setFilterPushedDown(boolean b)
void	setHBaseScanSpec(HBaseScanSpec hbaseScanSpec)	Do not use, only for testing.
void	setRegionsToScan(NavigableMap<org.apache.hadoop.hbase.HRegionInfo,org.apache.hadoop.hbase.ServerName> regionsToScan)	Do not use, only for testing.
String	toString()

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

accept, applyFilter, applyLimit, enforceWidth, getAnalyzeInfoProvider, getColumnValueCount, getDistributionAffinity, getFiles, getFilter, getInitialAllocation, getMaxAllocation, getMetadataProvider, getMinParallelizationWidth, 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

HBaseGroupScan

public HBaseGroupScan(String userName,
 HBaseScanSpec hbaseScanSpec,
 HBaseStoragePluginConfig storagePluginConfig,
 List<SchemaPath> columns,
 StoragePluginRegistry pluginRegistry)
               throws IOException,
ExecutionSetupException

Throws:

IOException

ExecutionSetupException

HBaseGroupScan

public HBaseGroupScan(String userName,
 HBaseStoragePlugin storagePlugin,
 HBaseScanSpec scanSpec,
 List<SchemaPath> columns)

HBaseGroupScan

public HBaseGroupScan()

Empty constructor, do not use, only for testing.

Method Details

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

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)

Specified by:

applyAssignments in interface GroupScan

getSpecificScan

public HBaseSubScan getSpecificScan(int minorFragmentId)

Specified by:

getSpecificScan in interface GroupScan

getMaxParallelizationWidth

public int getMaxParallelizationWidth()

Specified by:

getMaxParallelizationWidth 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

Parameters:

children -

getStoragePlugin

public HBaseStoragePlugin getStoragePlugin()

getHBaseConf

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

getTableName

public String getTableName()

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.

Specified by:

getDigest in interface GroupScan

toString

public String toString()

Overrides:

toString in class Object

getStorageConfig

public HBaseStoragePluginConfig getStorageConfig()

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

getHBaseScanSpec

public HBaseScanSpec getHBaseScanSpec()

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)

isFilterPushedDown

public boolean isFilterPushedDown()

setHBaseScanSpec

public void setHBaseScanSpec(HBaseScanSpec hbaseScanSpec)

Do not use, only for testing.

setRegionsToScan

public void setRegionsToScan(NavigableMap<org.apache.hadoop.hbase.HRegionInfo,org.apache.hadoop.hbase.ServerName> regionsToScan)

Do not use, only for testing.