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

Class FileScanFramework.FileReaderFactory

java.lang.Object

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

All Implemented Interfaces:

ManagedScanFramework.ReaderFactory

Direct Known Subclasses:

HDF5FormatPlugin.HDF5ReaderFactory, ShpFormatPlugin.ShpReaderFactory, XMLFormatPlugin.XMLReaderFactory

Enclosing class:

FileScanFramework

public abstract static class FileScanFramework.FileReaderFactory
extends Object
implements ManagedScanFramework.ReaderFactory

Iterates over the splits for the present scan. For each, creates a new reader. The file framework passes the file split (and the Drill file system) in via the schema negotiator at open time. This protocol makes clear that the constructor for the reader should do nothing; work should be done in the open() call.

Constructor Summary

Constructors

Constructor and Description
FileReaderFactory()

Method Summary

Modifier and Type	Method and Description
void	bind(ManagedScanFramework baseFramework)
CustomErrorContext	errorContext()
protected Optional<FileScanFramework>	fileFramework()
abstract ManagedReader<? extends FileScanFramework.FileSchemaNegotiator>	newReader()
ManagedReader<? extends SchemaNegotiator>	next()

Methods inherited from class java.lang.Object

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

Constructor Detail

FileReaderFactory

public FileReaderFactory()

Method Detail

bind

public void bind(ManagedScanFramework baseFramework)

Specified by:

bind in interface ManagedScanFramework.ReaderFactory

next

public ManagedReader<? extends SchemaNegotiator> next()

Specified by:

next in interface ManagedScanFramework.ReaderFactory

errorContext

public CustomErrorContext errorContext()

newReader

public abstract ManagedReader<? extends FileScanFramework.FileSchemaNegotiator> newReader()

fileFramework

protected Optional<FileScanFramework> fileFramework()

Returns:

FileScanFramework or empty object in case it is not binded yet with bind(ManagedScanFramework)