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

Class RestrictedJsonTableGroupScan

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.json.JsonTableGroupScan

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

All Implemented Interfaces:

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

public class RestrictedJsonTableGroupScan
extends JsonTableGroupScan

A RestrictedJsonTableGroupScan encapsulates (along with a subscan) the functionality for doing restricted (i.e skip) scan rather than sequential scan. The skipping is based on a supplied set of row keys (primary keys) from a join operator.

Field Summary

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

forcedRowCountMap, fullTableEstimatedSize, fullTableRowCount, maxRecordsToRead, parallelizationWidth, scanSpec, STAR_COLS, stats, TABLE_JSON

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.physical.base.GroupScan

ALL_COLUMNS

Constructor Summary

Constructors

Constructor and Description
RestrictedJsonTableGroupScan(String userName, FileSystemPlugin storagePlugin, MapRDBFormatPlugin formatPlugin, JsonScanSpec scanSpec, List<SchemaPath> columns, MapRDBStatistics statistics, TupleMetadata schema)

Method Summary

Modifier and Type	Method and Description
GroupScan	clone(JsonScanSpec scanSpec)
GroupScan	clone(List<SchemaPath> columns) Returns a clone of GroupScan instance, except that the new GroupScan will use the provided list of columns .
PhysicalOperator	getNewWithChildren(List<PhysicalOperator> children) Regenerate with this node with a new set of children.
protected NavigableMap<TabletFragmentInfo,String>	getRegionsToScan()
ScanStats	getScanStats()
MapRDBSubScan	getSpecificScan(int minorFragmentId)
protected RestrictedMapRDBSubScanSpec	getSubScanSpec(TabletFragmentInfo tfi)
boolean	isRestrictedScan() Whether this DbGroupScan is itself a restricted scan
String	toString()

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

applyLimit, canPushdownProjects, convertToQueryCondition, getAverageRowSizeStats, getColumns, getFirstKeyEstimatedStats, getIndexDesc, getMaxParallelizationWidth, getRangePartitionFunction, getRegionsToScan, getRestrictedScan, getRowCount, getScanSpec, getStatistics, getTableName, isDisablePushdown, isDistributed, isIndexScan, setColumns, setParallelizationWidth, setRowCount, setStatistics, supportsLimitPushdown, supportsRestrictedScan, supportsSecondaryIndex

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

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

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

getRowKeyName, getRowKeyPath

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

accept, applyFilter, enforceWidth, getAnalyzeInfoProvider, getColumnValueCount, getDistributionAffinity, getFiles, getFilter, getInitialAllocation, getMaxAllocation, getMinParallelizationWidth, getOperatorType, getPartitionColumns, getScanStats, getScanStats, getSelectionRoot, hasFiles, isExecutable, iterator, supportsFilterPushDown, 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.IndexGroupScan

getRowKeyOrdinal

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

applyAssignments, applyFilter, enforceWidth, getAnalyzeInfoProvider, getColumnValueCount, getDigest, getFiles, getFilter, getMetadataProvider, getMinParallelizationWidth, getPartitionColumns, getScanStats, getScanStats, getSelectionRoot, getTableMetadata, hasFiles, supportsFilterPushDown, 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, getOperatorAffinity

Constructor Detail

RestrictedJsonTableGroupScan

public RestrictedJsonTableGroupScan(String userName,
                                    FileSystemPlugin storagePlugin,
                                    MapRDBFormatPlugin formatPlugin,
                                    JsonScanSpec scanSpec,
                                    List<SchemaPath> columns,
                                    MapRDBStatistics statistics,
                                    TupleMetadata schema)

Method Detail

getSubScanSpec

protected RestrictedMapRDBSubScanSpec getSubScanSpec(TabletFragmentInfo tfi)

Overrides:

getSubScanSpec in class JsonTableGroupScan

getRegionsToScan

protected NavigableMap<TabletFragmentInfo,String> getRegionsToScan()

Overrides:

getRegionsToScan in class JsonTableGroupScan

getSpecificScan

public MapRDBSubScan getSpecificScan(int minorFragmentId)

Specified by:

getSpecificScan in interface GroupScan

Overrides:

getSpecificScan in class JsonTableGroupScan

clone

public GroupScan clone(JsonScanSpec scanSpec)

Overrides:

clone in class JsonTableGroupScan

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 JsonTableGroupScan

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

Overrides:

getNewWithChildren in class JsonTableGroupScan

getScanStats

public ScanStats getScanStats()

Overrides:

getScanStats in class JsonTableGroupScan

isRestrictedScan

public boolean isRestrictedScan()

Description copied from interface: DbGroupScan

Whether this DbGroupScan is itself a restricted scan

Specified by:

isRestrictedScan in interface DbGroupScan

Overrides:

isRestrictedScan in class AbstractDbGroupScan

Returns:

true if this DbGroupScan is itself a restricted scan, false otherwise

toString

public String toString()

Overrides:

toString in class JsonTableGroupScan