org.apache.drill.exec.store.mongo

Class MongoGroupScan

java.lang.Object

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

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

org.apache.drill.exec.store.mongo.MongoGroupScan

All Implemented Interfaces:

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

public class MongoGroupScan
extends AbstractGroupScan
implements DrillMongoConstants

Field Summary

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

INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation

Fields inherited from interface org.apache.drill.exec.store.mongo.DrillMongoConstants

CHUNKS, CONFIG, COUNT, DATABASES, HOST, ID, MAX, MIN, NS, PARTITIONED, PASSWORD_CONFIG_SUFFIX, PRIMARY, SHARD, SHARDS, SIZE, STORE_CONFIG_PREFIX, SYS_STORE_PROVIDER_MONGO_URL, USERNAME_CONFIG_SUFFIX

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

ALL_COLUMNS

Constructor Summary

Constructors

Constructor and Description
MongoGroupScan(String userName, MongoScanSpec scanSpec, MongoStoragePluginConfig storagePluginConfig, List<SchemaPath> columns, StoragePluginRegistry pluginRegistry, int maxRecords)
MongoGroupScan(String userName, MongoStoragePlugin storagePlugin, MongoScanSpec scanSpec, List<SchemaPath> columns, int maxRecords)

Method Summary

Modifier and Type	Method and Description
void	applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)
GroupScan	applyLimit(int maxRecords) By default, return null to indicate row count based prune is not supported.
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(int maxRecords)
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.
int	getMaxParallelizationWidth()
int	getMaxRecords()
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.
MongoScanSpec	getScanSpec()
ScanStats	getScanStats()
MongoSubScan	getSpecificScan(int minorFragmentId)
MongoStoragePluginConfig	getStorageConfig()
MongoStoragePlugin	getStoragePlugin()
boolean	isFilterPushedDown()
void	setFilterPushedDown(boolean filterPushedDown)
boolean	supportsLimitPushdown() Default is not to support limit pushdown.
String	toString()

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

accept, applyFilter, enforceWidth, getAnalyzeInfoProvider, getColumnValueCount, getDistributionAffinity, getFiles, getFilter, getInitialAllocation, getMaxAllocation, getMetadataProvider, getMinParallelizationWidth, getOperatorType, getPartitionColumns, getScanStats, getSelectionRoot, getTableMetadata, hasFiles, isDistributed, 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.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

MongoGroupScan

public MongoGroupScan(String userName,
                      MongoScanSpec scanSpec,
                      MongoStoragePluginConfig storagePluginConfig,
                      List<SchemaPath> columns,
                      StoragePluginRegistry pluginRegistry,
                      int maxRecords)
               throws IOException

Throws:

IOException

MongoGroupScan

public MongoGroupScan(String userName,
                      MongoStoragePlugin storagePlugin,
                      MongoScanSpec scanSpec,
                      List<SchemaPath> columns,
                      int maxRecords)
               throws IOException

Throws:

IOException

Method Detail

isFilterPushedDown

public boolean isFilterPushedDown()

setFilterPushedDown

public void setFilterPushedDown(boolean filterPushedDown)

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

clone

public GroupScan clone(int maxRecords)

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

applyAssignments

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

Specified by:

applyAssignments in interface GroupScan

getSpecificScan

public MongoSubScan getSpecificScan(int minorFragmentId)

Specified by:

getSpecificScan in interface GroupScan

getMaxParallelizationWidth

public int getMaxParallelizationWidth()

Specified by:

getMaxParallelizationWidth in interface GroupScan

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

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

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.

supportsLimitPushdown

public boolean supportsLimitPushdown()

Description copied from class: AbstractGroupScan

Default is not to support limit pushdown.

Specified by:

supportsLimitPushdown in interface GroupScan

Overrides:

supportsLimitPushdown in class AbstractGroupScan

applyLimit

public GroupScan applyLimit(int maxRecords)

Description copied from class: AbstractGroupScan

By default, return null to indicate row count based prune is not supported. Each group scan subclass should override, if it supports row count based prune.

Specified by:

applyLimit in interface GroupScan

Overrides:

applyLimit in class AbstractGroupScan

Parameters:

maxRecords - : the number of rows requested from group scan.

Returns:

a new instance of group scan if the prune is successful. null when either if row-based prune is not supported, or if prune is not successful.

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

getScanSpec

public MongoScanSpec getScanSpec()

getStorageConfig

public MongoStoragePluginConfig getStorageConfig()

getMaxRecords

public int getMaxRecords()

getStoragePlugin

public MongoStoragePlugin getStoragePlugin()

toString

public String toString()

Overrides:

toString in class Object