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
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
bind
(FileScanLifecycle scan) boolean
hasNext()
abstract ManagedReader
newReader
(FileSchemaNegotiator negotiator) next
(FileSchemaNegotiator negotiator)
-
Constructor Details
-
FileReaderFactory
public FileReaderFactory()
-
-
Method Details
-
bind
-
hasNext
public boolean hasNext()- Specified by:
hasNext
in interfaceReaderFactory<FileSchemaNegotiator>
-
next
- Specified by:
next
in interfaceReaderFactory<FileSchemaNegotiator>
- Throws:
ManagedReader.EarlyEofException
-
newReader
public abstract ManagedReader newReader(FileSchemaNegotiator negotiator) throws ManagedReader.EarlyEofException - Throws:
ManagedReader.EarlyEofException
-