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

Class FileScanFramework.FileSchemaNegotiatorImpl

java.lang.Object

org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiatorImpl

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

All Implemented Interfaces:

FileScanFramework.FileSchemaNegotiator, SchemaNegotiator

Direct Known Subclasses:

ColumnsScanFramework.ColumnsSchemaNegotiatorImpl

Enclosing class:

FileScanFramework

public static class FileScanFramework.FileSchemaNegotiatorImpl
extends SchemaNegotiatorImpl
implements FileScanFramework.FileSchemaNegotiator

Implementation of the file-level schema negotiator. At present, no file-specific features exist. This class shows, however, where we would add such features.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiatorImpl

SchemaNegotiatorImpl.NegotiatorListener

Field Summary

Fields inherited from class org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiatorImpl

batchSize, context, framework, isSchemaComplete, providedSchema, tableSchema

Constructor Summary

Constructors

Constructor and Description
FileSchemaNegotiatorImpl(FileScanFramework framework)

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 class org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiatorImpl

batchSize, bind, build, context, drillConfig, errorContext, hasProvidedSchema, isProjectionEmpty, isSchemaComplete, parentErrorContext, providedSchema, queryOptions, setErrorContext, tableSchema, userName

Methods inherited from class java.lang.Object

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

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

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

Constructor Detail

FileSchemaNegotiatorImpl

public FileSchemaNegotiatorImpl(FileScanFramework framework)

Method Detail

fileSystem

public DrillFileSystem fileSystem()

Description copied from interface: FileScanFramework.FileSchemaNegotiator

Gives the Drill file system for this operator.

Specified by:

fileSystem in interface FileScanFramework.FileSchemaNegotiator

split

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

Description copied from interface: FileScanFramework.FileSchemaNegotiator

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

Specified by:

split in interface FileScanFramework.FileSchemaNegotiator

Returns:

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