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

Class FileSchemaNegotiatorImpl

java.lang.Object

org.apache.drill.exec.physical.impl.scan.v3.lifecycle.SchemaNegotiatorImpl

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

All Implemented Interfaces:

FileSchemaNegotiator, SchemaNegotiator

public class FileSchemaNegotiatorImpl
extends SchemaNegotiatorImpl
implements FileSchemaNegotiator

Implementation of the file-level schema negotiator which holds the file split which the reader is to process. This class presents the split in both Hadoop and Drill formats. Adds the file name to the error context.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	FileSchemaNegotiatorImpl.SplitErrorContext

Field Summary

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

baseErrorContext, batchSize, isSchemaComplete, readerErrorContext, readerLifecycle, readerSchema

Constructor Summary

Constructors

Constructor and Description
FileSchemaNegotiatorImpl(ReaderLifecycle readerLifecycle)

Method Summary

Modifier and Type	Method and Description
void	bindSplit(FileWork fileWork)
FileDescrip	file() Gives the file description which holds the Drill file system, split, file work and format-specific properties.
StaticBatchBuilder	implicitColumnsLoader()
ManagedReader	newReader(ReaderFactory<?> readerFactory)
protected void	onEndBatch()

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

batchSize, build, context, errorContext, inputSchema, isProjectionEmpty, isSchemaComplete, parentErrorContext, projectionFor, providedSchema, schemaIsComplete, setErrorContext, tableSchema, 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.v3.SchemaNegotiator

batchSize, build, context, errorContext, inputSchema, isProjectionEmpty, parentErrorContext, projectionFor, providedSchema, schemaIsComplete, setErrorContext, tableSchema, tableSchema, userName

Constructor Detail

FileSchemaNegotiatorImpl

public FileSchemaNegotiatorImpl(ReaderLifecycle readerLifecycle)

Method Detail

bindSplit

public void bindSplit(FileWork fileWork)

file

public FileDescrip file()

Description copied from interface: FileSchemaNegotiator

Gives the file description which holds the Drill file system, split, file work and format-specific properties. Can open the file and provides information used to populate implicit columns.

Specified by:

file in interface FileSchemaNegotiator

newReader

public ManagedReader newReader(ReaderFactory<?> readerFactory)
                        throws ManagedReader.EarlyEofException

Overrides:

newReader in class SchemaNegotiatorImpl

Throws:

ManagedReader.EarlyEofException

implicitColumnsLoader

public StaticBatchBuilder implicitColumnsLoader()

Overrides:

implicitColumnsLoader in class SchemaNegotiatorImpl

onEndBatch

protected void onEndBatch()

Overrides:

onEndBatch in class SchemaNegotiatorImpl