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, isThreadSafepublic QuotedLineBreakAccessor(InputData input)
input - all input parameters coming from the client requestpublic boolean openForRead()
throws java.lang.Exception
HdfsAtomicDataAccessoropenForRead in interface ReadAccessoropenForRead in class HdfsAtomicDataAccessorjava.lang.Exception - if opening the resource failedpublic OneRow readNextObject() throws java.io.IOException
readNextObject in interface ReadAccessorreadNextObject in class HdfsAtomicDataAccessorOneRow record as a Java object. Returns null if none.java.io.IOException