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

Class FileReaderFactory

java.lang.Object

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

All Implemented Interfaces:

ReaderFactory<FileSchemaNegotiator>

Direct Known Subclasses:

ShpFormatPlugin.ShpReaderFactory, XMLFormatPlugin.XMLReaderFactory

public abstract class FileReaderFactory
extends Object
implements ReaderFactory<FileSchemaNegotiator>

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 to the constructor which should open the file.

Constructor Summary

Constructors

Constructor	Description
FileReaderFactory()

Method Summary

Modifier and Type	Method	Description
protected void	bind(FileScanLifecycle scan)
boolean	hasNext()
abstract ManagedReader	newReader(FileSchemaNegotiator negotiator)
ManagedReader	next(FileSchemaNegotiator negotiator)

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

protected void bind(FileScanLifecycle scan)

hasNext

public boolean hasNext()

Specified by:

hasNext in interface ReaderFactory<FileSchemaNegotiator>

next

public ManagedReader next(FileSchemaNegotiator negotiator)
                   throws ManagedReader.EarlyEofException

Specified by:

next in interface ReaderFactory<FileSchemaNegotiator>

Throws:

ManagedReader.EarlyEofException

newReader

public abstract ManagedReader newReader(FileSchemaNegotiator negotiator)
                                 throws ManagedReader.EarlyEofException

Throws:

ManagedReader.EarlyEofException