Package org.apache.drill.exec.store.googlesheets

Class GoogleSheetsGroupScan

java.lang.Object

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

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

org.apache.drill.exec.store.googlesheets.GoogleSheetsGroupScan

All Implemented Interfaces:

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

public class GoogleSheetsGroupScan
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	Description
GoogleSheetsGroupScan(String userName, GoogleSheetsScanSpec scanSpec, List<SchemaPath> columns, Map<String,ExprNode.ColRelOpConstNode> filters, double selectivity, int maxRecords, StoragePluginRegistry plugins)
GoogleSheetsGroupScan(String userName, GoogleSheetsScanSpec scanSpec, GoogleSheetsStoragePlugin plugin, MetadataProviderManager metadataProviderManager)
GoogleSheetsGroupScan(GoogleSheetsGroupScan that)
GoogleSheetsGroupScan(GoogleSheetsGroupScan that, int maxRecords)	Constructor for applying a limit.
GoogleSheetsGroupScan(GoogleSheetsGroupScan that, List<SchemaPath> columns)	Constructor for applying columns (Projection pushdown).
GoogleSheetsGroupScan(GoogleSheetsGroupScan that, Map<String,ExprNode.ColRelOpConstNode> filters, double filterSelectivity)	Constructor for applying a filter

Method Summary

Modifier and Type	Method	Description
boolean	allowsFilters()
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(List<SchemaPath> columns)	Returns a clone of GroupScan instance, except that the new GroupScan will use the provided list of columns .
List<SchemaPath>	columns()
GoogleSheetsStoragePluginConfig	config()
boolean	equals(Object obj)
Map<String,ExprNode.ColRelOpConstNode>	filters()
String	getDigest()	Returns a signature of the GroupScan which should usually be composed of all its attributes which could describe it uniquely.
int	getMaxParallelizationWidth()
TableMetadataProvider	getMetadataProvider()	Returns TableMetadataProvider instance which is used for providing metadata for current GroupScan.
PhysicalOperator	getNewWithChildren(List<PhysicalOperator> children)	Regenerate with this node with a new set of children.
ScanStats	getScanStats()
TupleMetadata	getSchema()
SubScan	getSpecificScan(int minorFragmentId)
TableMetadata	getTableMetadata()
boolean	hasFilters()
int	hashCode()
int	maxRecords()
GoogleSheetsScanSpec	scanSpec()
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, getColumns, getColumnValueCount, getDistributionAffinity, getFiles, getFilter, getInitialAllocation, getMaxAllocation, getMinParallelizationWidth, getOperatorAffinity, getOperatorType, getPartitionColumns, getScanStats, getScanStats, getSelectionRoot, 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, finalize, getClass, notify, notifyAll, wait, wait, wait

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

accept

Methods inherited from interface java.lang.Iterable

forEach, spliterator

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

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

Constructor Details

GoogleSheetsGroupScan

public GoogleSheetsGroupScan(String userName,
 GoogleSheetsScanSpec scanSpec,
 GoogleSheetsStoragePlugin plugin,
 MetadataProviderManager metadataProviderManager)

GoogleSheetsGroupScan

public GoogleSheetsGroupScan(GoogleSheetsGroupScan that)

GoogleSheetsGroupScan

public GoogleSheetsGroupScan(GoogleSheetsGroupScan that,
 int maxRecords)

Constructor for applying a limit.

Parameters:

that - The previous group scan without the limit.

maxRecords - The desired limit, pushed down from Calcite

GoogleSheetsGroupScan

public GoogleSheetsGroupScan(GoogleSheetsGroupScan that,
 List<SchemaPath> columns)

Constructor for applying columns (Projection pushdown).

Parameters:

that - The previous GroupScan, without the columns

columns - The list of columns to push down

GoogleSheetsGroupScan

public GoogleSheetsGroupScan(GoogleSheetsGroupScan that,
 Map<String,ExprNode.ColRelOpConstNode> filters,
 double filterSelectivity)

Constructor for applying a filter

Parameters:

that - Previous group scan w/o filters

filters - The list of filters

filterSelectivity - The filter selectivity

GoogleSheetsGroupScan

public GoogleSheetsGroupScan(String userName,
 GoogleSheetsScanSpec scanSpec,
 List<SchemaPath> columns,
 Map<String,ExprNode.ColRelOpConstNode> filters,
 double selectivity,
 int maxRecords,
 StoragePluginRegistry plugins)

Method Details

scanSpec

public GoogleSheetsScanSpec scanSpec()

config

public GoogleSheetsStoragePluginConfig config()

columns

public List<SchemaPath> columns()

filters

public Map<String,ExprNode.ColRelOpConstNode> filters()

maxRecords

public int maxRecords()

applyAssignments

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

getSchema

public TupleMetadata getSchema()

getTableMetadata

public TableMetadata getTableMetadata()

Specified by:

getTableMetadata in interface GroupScan

Overrides:

getTableMetadata in class AbstractGroupScan

getMetadataProvider

public TableMetadataProvider getMetadataProvider()

Description copied from interface: GroupScan

Returns TableMetadataProvider instance which is used for providing metadata for current GroupScan.

Specified by:

getMetadataProvider in interface GroupScan

Overrides:

getMetadataProvider in class AbstractGroupScan

Returns:

TableMetadataProvider instance the source of metadata

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

allowsFilters

public boolean allowsFilters()

getSpecificScan

public SubScan getSpecificScan(int minorFragmentId)

getMaxParallelizationWidth

public int getMaxParallelizationWidth()

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

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.

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.

getScanStats

public ScanStats getScanStats()

Overrides:

getScanStats in class AbstractGroupScan

hasFilters

public boolean hasFilters()

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.

Parameters:

children -

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