org.apache.drill.exec.store.phoenix

Class PhoenixGroupScan

java.lang.Object

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

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

org.apache.drill.exec.store.phoenix.PhoenixGroupScan

All Implemented Interfaces:

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

public class PhoenixGroupScan
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 and Description
PhoenixGroupScan(PhoenixGroupScan scan)
PhoenixGroupScan(PhoenixGroupScan scan, List<SchemaPath> columns)
PhoenixGroupScan(String userName, PhoenixScanSpec scanSpec, PhoenixStoragePlugin plugin)
PhoenixGroupScan(String user, String sql, List<SchemaPath> columns, PhoenixScanSpec scanSpec, PhoenixStoragePlugin plugin)
PhoenixGroupScan(String userName, String sql, List<SchemaPath> columns, PhoenixScanSpec scanSpec, PhoenixStoragePluginConfig config, StoragePluginRegistry plugins)

Method Summary

Modifier and Type	Method and Description
void	applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)
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>	columns()
StoragePluginConfig	config()
boolean	equals(Object obj)
String	getDigest() Returns a signature of the GroupScan which should usually be composed of all its attributes which could describe it uniquely.
int	getMaxParallelizationWidth()
PhysicalOperator	getNewWithChildren(List<PhysicalOperator> children) Regenerate with this node with a new set of children.
SubScan	getSpecificScan(int minorFragmentId)
int	hashCode()
PhoenixStoragePlugin	plugin()
PhoenixScanSpec	scanSpec()
String	sql()
String	toString()

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

accept, applyFilter, applyLimit, canPushdownProjects, 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, finalize, getClass, notify, notifyAll, wait, wait, wait

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

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

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

accept

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

PhoenixGroupScan

public PhoenixGroupScan(String userName,
                        String sql,
                        List<SchemaPath> columns,
                        PhoenixScanSpec scanSpec,
                        PhoenixStoragePluginConfig config,
                        StoragePluginRegistry plugins)

PhoenixGroupScan

public PhoenixGroupScan(String userName,
                        PhoenixScanSpec scanSpec,
                        PhoenixStoragePlugin plugin)

PhoenixGroupScan

public PhoenixGroupScan(PhoenixGroupScan scan)

PhoenixGroupScan

public PhoenixGroupScan(PhoenixGroupScan scan,
                        List<SchemaPath> columns)

PhoenixGroupScan

public PhoenixGroupScan(String user,
                        String sql,
                        List<SchemaPath> columns,
                        PhoenixScanSpec scanSpec,
                        PhoenixStoragePlugin plugin)

Method Detail

sql

public String sql()

columns

public List<SchemaPath> columns()

scanSpec

public PhoenixScanSpec scanSpec()

plugin

public PhoenixStoragePlugin plugin()

config

public StoragePluginConfig config()

applyAssignments

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

Throws:

PhysicalOperatorSetupException

getSpecificScan

public SubScan getSpecificScan(int minorFragmentId)
                        throws ExecutionSetupException

Throws:

ExecutionSetupException

getMaxParallelizationWidth

public int getMaxParallelizationWidth()

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)
                                    throws ExecutionSetupException

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.

Throws:

ExecutionSetupException

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

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object