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

Class RestrictedMapRDBSubScan

java.lang.Object

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

org.apache.drill.exec.physical.base.AbstractSubScan

org.apache.drill.exec.physical.base.AbstractDbSubScan

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

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

All Implemented Interfaces:

Iterable<PhysicalOperator>, GraphValue<PhysicalOperator>, DbSubScan, FragmentLeaf, Leaf, PhysicalOperator, Scan, SubScan

public class RestrictedMapRDBSubScan
extends MapRDBSubScan

A RestrictedMapRDBSubScan is intended for skip-scan (as opposed to sequential scan) operations where the set of rowkeys is obtained from a corresponding RowKeyJoin instance

Field Summary

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

OPERATOR_TYPE

Fields inherited from class org.apache.drill.exec.physical.base.AbstractBase

INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation

Constructor Summary

Constructors

Constructor and Description
RestrictedMapRDBSubScan(StoragePluginRegistry engineRegistry, String userName, MapRDBFormatPluginConfig formatPluginConfig, StoragePluginConfig storageConfig, List<RestrictedMapRDBSubScanSpec> regionScanSpecList, List<SchemaPath> columns, int maxRecordsToRead, String tableType, TupleMetadata schema)
RestrictedMapRDBSubScan(String userName, MapRDBFormatPlugin formatPlugin, List<RestrictedMapRDBSubScanSpec> maprDbSubScanSpecs, List<SchemaPath> columns, int maxRecordsToRead, String tableType, TupleMetadata schema)

Method Summary

Modifier and Type	Method and Description
void	addJoinForRestrictedSubScan(RowKeyJoin rjbatch) For a restricted sub-scan, this method allows associating a rowkey join instance.
boolean	isRestrictedSubScan() Whether this subscan is a restricted (skip) subscan

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

accept, getColumns, getFormatPlugin, getFormatPluginConfig, getMaxRecordsToRead, getNewWithChildren, getOperatorType, getRegionScanSpecList, getSchema, getStorageConfig, getTableType, isExecutable, iterator

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

accept, getSVMode

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

getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

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

RestrictedMapRDBSubScan

public RestrictedMapRDBSubScan(StoragePluginRegistry engineRegistry,
                               String userName,
                               MapRDBFormatPluginConfig formatPluginConfig,
                               StoragePluginConfig storageConfig,
                               List<RestrictedMapRDBSubScanSpec> regionScanSpecList,
                               List<SchemaPath> columns,
                               int maxRecordsToRead,
                               String tableType,
                               TupleMetadata schema)
                        throws ExecutionSetupException

Throws:

ExecutionSetupException

RestrictedMapRDBSubScan

public RestrictedMapRDBSubScan(String userName,
                               MapRDBFormatPlugin formatPlugin,
                               List<RestrictedMapRDBSubScanSpec> maprDbSubScanSpecs,
                               List<SchemaPath> columns,
                               int maxRecordsToRead,
                               String tableType,
                               TupleMetadata schema)

Method Detail

addJoinForRestrictedSubScan

public void addJoinForRestrictedSubScan(RowKeyJoin rjbatch)

Description copied from interface: DbSubScan

For a restricted sub-scan, this method allows associating a rowkey join instance. A subscan within a minor fragment must have a corresponding rowkey join batch instance from which it will retrieve its set of rowkeys to perform the restricted scan.

Specified by:

addJoinForRestrictedSubScan in interface DbSubScan

Overrides:

addJoinForRestrictedSubScan in class AbstractDbSubScan

isRestrictedSubScan

public boolean isRestrictedSubScan()

Description copied from interface: DbSubScan

Whether this subscan is a restricted (skip) subscan

Specified by:

isRestrictedSubScan in interface DbSubScan

Overrides:

isRestrictedSubScan in class AbstractDbSubScan

Returns:

true if this subscan is a restricted subscan, false otherwise