public class FileScanLifecycleBuilder extends ScanLifecycleBuilder
ScanLifecycleBuilder.DummyReaderFactory, ScanLifecycleBuilder.SchemaValidator
Modifier and Type | Field and Description |
---|---|
protected int |
maxPartitionDepth |
protected org.apache.hadoop.fs.Path |
rootDir |
protected boolean |
useLegacyWildcardExpansion |
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 and Description |
---|
FileScanLifecycleBuilder() |
Modifier and Type | Method and 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) |
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
protected int maxPartitionDepth
protected boolean useLegacyWildcardExpansion
protected org.apache.hadoop.fs.Path rootDir
public void fileSystemConfig(org.apache.hadoop.conf.Configuration fsConf)
public void fileSplitImpls(List<CompleteFileWork.FileWorkImpl> splits)
public void maxPartitionDepth(int maxPartitionDepth)
public void useLegacyWildcardExpansion(boolean useLegacyWildcardExpansion)
public void rootDir(org.apache.hadoop.fs.Path rootDir)
public void compressible(boolean compressible)
public org.apache.hadoop.conf.Configuration fileSystemConfig()
public int maxPartitionDepth()
public boolean useLegacyWildcardExpansion()
public org.apache.hadoop.fs.Path rootDir()
public boolean isCompressible()
public ScanLifecycle build(OperatorContext context)
build
in class ScanLifecycleBuilder
Copyright © 1970 The Apache Software Foundation. All rights reserved.