public class QuotedLineBreakAccessor extends HdfsAtomicDataAccessor
inp
Constructor and Description |
---|
QuotedLineBreakAccessor(InputData input)
Constructs a QuotedLineBreakAccessor.
|
Modifier and Type | Method and Description |
---|---|
boolean |
openForRead()
Opens the file using the non-splittable API for HADOOP HDFS file access
This means that instead of using a FileInputFormat for access, we use a
Java stream.
|
OneRow |
readNextObject()
Fetches one record (maybe partial) from the file.
|
closeForRead, isThreadSafe
public QuotedLineBreakAccessor(InputData input)
input
- all input parameters coming from the client requestpublic boolean openForRead() throws java.lang.Exception
HdfsAtomicDataAccessor
openForRead
in interface ReadAccessor
openForRead
in class HdfsAtomicDataAccessor
java.lang.Exception
- if opening the resource failedpublic OneRow readNextObject() throws java.io.IOException
readNextObject
in interface ReadAccessor
readNextObject
in class HdfsAtomicDataAccessor
OneRow
record as a Java object. Returns null if none.java.io.IOException