Package org.apache.drill.exec.store.dfs.easy

Class EasySubScan

java.lang.Object

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

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

org.apache.drill.exec.store.dfs.easy.EasySubScan

All Implemented Interfaces:

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

public class EasySubScan
extends AbstractSubScan

Field Summary

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

INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName

Constructor Summary

Constructors

Constructor	Description
EasySubScan(String userName, List<CompleteFileWork.FileWorkImpl> files, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, StoragePluginRegistry engineRegistry, List<SchemaPath> columns, org.apache.hadoop.fs.Path selectionRoot, int partitionDepth, TupleMetadata schema, int limit)
EasySubScan(String userName, List<CompleteFileWork.FileWorkImpl> files, EasyFormatPlugin<?> plugin, List<SchemaPath> columns, org.apache.hadoop.fs.Path selectionRoot, int partitionDepth, TupleMetadata schema, int limit)

Method Summary

Modifier and Type	Method	Description
List<SchemaPath>	getColumns()
FormatPluginConfig	getFormatConfig()
EasyFormatPlugin<?>	getFormatPlugin()
int	getLimit()
int	getMaxRecords()
String	getOperatorType()
int	getPartitionDepth()
TupleMetadata	getSchema()
org.apache.hadoop.fs.Path	getSelectionRoot()
StoragePluginConfig	getStorageConfig()
List<CompleteFileWork.FileWorkImpl>	getWorkUnits()

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

accept, accept, getNewWithChildren, getSVMode, isExecutable, iterator

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 java.lang.Iterable

forEach, spliterator

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

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

Constructor Details

EasySubScan

public EasySubScan(String userName,
 List<CompleteFileWork.FileWorkImpl> files,
 StoragePluginConfig storageConfig,
 FormatPluginConfig formatConfig,
 StoragePluginRegistry engineRegistry,
 List<SchemaPath> columns,
 org.apache.hadoop.fs.Path selectionRoot,
 int partitionDepth,
 TupleMetadata schema,
 int limit)
            throws ExecutionSetupException

Throws:

ExecutionSetupException

EasySubScan

public EasySubScan(String userName,
 List<CompleteFileWork.FileWorkImpl> files,
 EasyFormatPlugin<?> plugin,
 List<SchemaPath> columns,
 org.apache.hadoop.fs.Path selectionRoot,
 int partitionDepth,
 TupleMetadata schema,
 int limit)

Method Details

getSelectionRoot

public org.apache.hadoop.fs.Path getSelectionRoot()

getPartitionDepth

public int getPartitionDepth()

getFormatPlugin

public EasyFormatPlugin<?> getFormatPlugin()

getWorkUnits

public List<CompleteFileWork.FileWorkImpl> getWorkUnits()

getStorageConfig

public StoragePluginConfig getStorageConfig()

getFormatConfig

public FormatPluginConfig getFormatConfig()

getColumns

public List<SchemaPath> getColumns()

getSchema

public TupleMetadata getSchema()

getLimit

public int getLimit()

getMaxRecords

public int getMaxRecords()

getOperatorType

public String getOperatorType()