Package org.apache.drill.exec.physical.impl.scan.v3.file

Class FileScanLifecycleBuilder

java.lang.Object

org.apache.drill.exec.physical.impl.scan.v3.ScanLifecycleBuilder

org.apache.drill.exec.physical.impl.scan.v3.file.FileScanLifecycleBuilder

Direct Known Subclasses:

EasyFileScanBuilder

public class FileScanLifecycleBuilder
extends ScanLifecycleBuilder

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.physical.impl.scan.v3.ScanLifecycleBuilder

ScanLifecycleBuilder.DummyReaderFactory, ScanLifecycleBuilder.SchemaValidator

Field Summary

Fields

Modifier and Type	Field	Description
protected int	maxPartitionDepth
protected org.apache.hadoop.fs.Path	rootDir
protected boolean	useLegacyWildcardExpansion

Fields inherited from class org.apache.drill.exec.physical.impl.scan.v3.ScanLifecycleBuilder

allowRequiredNullColumns, allowSchemaChange, DEFAULT_BATCH_BYTE_COUNT, DEFAULT_BATCH_ROW_COUNT, definedSchema, disableEmptyResults, enableSchemaBatch, errorContext, MAX_BATCH_BYTE_SIZE, MAX_BATCH_ROW_COUNT, MIN_BATCH_BYTE_SIZE, nullType, providedSchema, schemaValidator, userName

Constructor Summary

Constructors

Constructor	Description
FileScanLifecycleBuilder()

Method Summary

Modifier and Type	Method	Description
ScanLifecycle	build(OperatorContext context)
void	compressible(boolean compressible)
void	fileSplitImpls(List<CompleteFileWork.FileWorkImpl> splits)	Legacy version because the file scan operator exposes the implementation, not the interface.
void	fileSplits(List<FileWork> splits)
org.apache.hadoop.conf.Configuration	fileSystemConfig()
void	fileSystemConfig(org.apache.hadoop.conf.Configuration fsConf)
boolean	isCompressible()
int	maxPartitionDepth()
void	maxPartitionDepth(int maxPartitionDepth)
org.apache.hadoop.fs.Path	rootDir()
void	rootDir(org.apache.hadoop.fs.Path rootDir)
List<FileWork>	splits()
boolean	useLegacyWildcardExpansion()
void	useLegacyWildcardExpansion(boolean useLegacyWildcardExpansion)

Methods inherited from class org.apache.drill.exec.physical.impl.scan.v3.ScanLifecycleBuilder

allowRequiredNullColumns, allowRequiredNullColumns, allowSchemaChange, allowSchemaChange, batchByteLimit, batchRecordLimit, buildScan, buildScanOperator, definedSchema, definedSchema, disableEmptyResults, enableSchemaBatch, errorContext, errorContext, limit, limit, nullType, nullType, options, options, projection, projection, providedSchema, providedSchema, readerFactory, readerFactory, scanBatchByteLimit, scanBatchRecordLimit, schemaValidator, schemaValidator, userName, userName

Methods inherited from class java.lang.Object

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

Field Details

maxPartitionDepth

protected int maxPartitionDepth

useLegacyWildcardExpansion

protected boolean useLegacyWildcardExpansion

rootDir

protected org.apache.hadoop.fs.Path rootDir

Constructor Details

FileScanLifecycleBuilder

public FileScanLifecycleBuilder()

Method Details

fileSystemConfig

public void fileSystemConfig(org.apache.hadoop.conf.Configuration fsConf)

fileSplits

public void fileSplits(List<FileWork> splits)

fileSplitImpls

public void fileSplitImpls(List<CompleteFileWork.FileWorkImpl> splits)

Legacy version because the file scan operator exposes the implementation, not the interface.

maxPartitionDepth

public void maxPartitionDepth(int maxPartitionDepth)

useLegacyWildcardExpansion

public void useLegacyWildcardExpansion(boolean useLegacyWildcardExpansion)

rootDir

public void rootDir(org.apache.hadoop.fs.Path rootDir)

compressible

public void compressible(boolean compressible)

splits

public List<FileWork> splits()

fileSystemConfig

public org.apache.hadoop.conf.Configuration fileSystemConfig()

maxPartitionDepth

public int maxPartitionDepth()

useLegacyWildcardExpansion

public boolean useLegacyWildcardExpansion()

rootDir

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

isCompressible

public boolean isCompressible()

build

public ScanLifecycle build(OperatorContext context)

Overrides:

build in class ScanLifecycleBuilder