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

Interface FileScanFramework.FileSchemaNegotiator

All Superinterfaces:

SchemaNegotiator

All Known Subinterfaces:

ColumnsSchemaNegotiator

All Known Implementing Classes:

ColumnsScanFramework.ColumnsSchemaNegotiatorImpl, FileScanFramework.FileSchemaNegotiatorImpl

Enclosing class:

FileScanFramework

public static interface FileScanFramework.FileSchemaNegotiator
extends SchemaNegotiator

The file schema negotiator adds no behavior at present, but is created as a placeholder anticipating the need for file-specific behavior later. Readers are expected to use an instance of this class so that their code need not change later if/when we add new methods. For example, perhaps we want to specify an assumed block size for S3 files, or want to specify behavior if the file no longer exists. Those are out of scope of this first round of changes which focus on schema.

Method Summary

Modifier and Type	Method and Description
DrillFileSystem	fileSystem() Gives the Drill file system for this operator.
org.apache.hadoop.mapred.FileSplit	split() Describes the file split (path and block offset) for this scan.

Methods inherited from interface org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator

batchSize, build, context, drillConfig, hasProvidedSchema, isProjectionEmpty, limit, parentErrorContext, providedSchema, queryOptions, setErrorContext, tableSchema, userName

Method Detail

fileSystem

DrillFileSystem fileSystem()

Gives the Drill file system for this operator.

split

org.apache.hadoop.mapred.FileSplit split()

Describes the file split (path and block offset) for this scan.

Returns:

Hadoop file split object with the file path, block offset, and length.