Package 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

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	Description
FileReaderFactory()

Method Summary

Modifier and Type	Method	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 Details

FileReaderFactory

public FileReaderFactory()

Method Details

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)