public class KuduGroupScan extends AbstractGroupScan
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
ALL_COLUMNS
Constructor and Description |
---|
KuduGroupScan()
Empty constructor, do not use, only for testing.
|
KuduGroupScan(KuduScanSpec kuduScanSpec,
KuduStoragePluginConfig kuduStoragePluginConfig,
List<SchemaPath> columns,
StoragePluginRegistry pluginRegistry) |
KuduGroupScan(KuduStoragePlugin kuduStoragePlugin,
KuduScanSpec kuduScanSpec,
List<SchemaPath> columns) |
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.
|
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. |
KuduScanSpec |
getKuduScanSpec() |
KuduStoragePluginConfig |
getKuduStoragePluginConfig() |
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() |
KuduSubScan |
getSpecificScan(int minorFragmentId) |
KuduStoragePlugin |
getStoragePlugin() |
String |
getTableName() |
boolean |
isFilterPushedDown() |
void |
setFilterPushedDown(boolean b) |
void |
setKuduScanSpec(KuduScanSpec kuduScanSpec)
Do not use, only for testing.
|
String |
toString() |
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
accept, getCost, getOperatorId, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getCost, getOperatorId, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId
accept
forEach, spliterator
public KuduGroupScan(KuduScanSpec kuduScanSpec, KuduStoragePluginConfig kuduStoragePluginConfig, List<SchemaPath> columns, StoragePluginRegistry pluginRegistry) throws IOException, ExecutionSetupException
IOException
ExecutionSetupException
public KuduGroupScan(KuduStoragePlugin kuduStoragePlugin, KuduScanSpec kuduScanSpec, List<SchemaPath> columns)
public KuduGroupScan()
public GroupScan clone(List<SchemaPath> columns)
GroupScan
clone
in interface GroupScan
clone
in class AbstractGroupScan
public List<EndpointAffinity> getOperatorAffinity()
HasAffinity
getOperatorAffinity
in interface HasAffinity
getOperatorAffinity
in class AbstractGroupScan
public int getMaxParallelizationWidth()
public void applyAssignments(List<CoordinationProtos.DrillbitEndpoint> incomingEndpoints)
incomingEndpoints
- public KuduSubScan getSpecificScan(int minorFragmentId)
public ScanStats getScanStats()
getScanStats
in class AbstractGroupScan
public PhysicalOperator getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator
public KuduStoragePlugin getStoragePlugin()
public String getTableName()
public String getDigest()
GroupScan
GroupScan
which should usually be composed of
all its attributes which could describe it uniquely.public KuduStoragePluginConfig getKuduStoragePluginConfig()
public List<SchemaPath> getColumns()
GroupScan
getColumns
in interface GroupScan
getColumns
in class AbstractGroupScan
public KuduScanSpec getKuduScanSpec()
public boolean canPushdownProjects(List<SchemaPath> columns)
GroupScan
canPushdownProjects
in interface GroupScan
canPushdownProjects
in class AbstractGroupScan
public void setFilterPushedDown(boolean b)
public boolean isFilterPushedDown()
public void setKuduScanSpec(KuduScanSpec kuduScanSpec)
Copyright © 2022 The Apache Software Foundation. All rights reserved.