public class ReadBridge extends java.lang.Object implements Bridge
| Constructor and Description |
|---|
ReadBridge(ProtocolData protData)
C'tor - set the implementation of the bridge.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
beginIteration()
Accesses the underlying HDFS file.
|
static ReadResolver |
getFieldsResolver(InputData inputData) |
static ReadAccessor |
getFileAccessor(InputData inputData) |
Writable |
getNext()
Fetches next object from file and turn it into a record that the HAWQ
backend can process.
|
boolean |
isThreadSafe() |
boolean |
setNext(java.io.DataInputStream inputStream) |
public ReadBridge(ProtocolData protData) throws java.lang.Exception
protData - input containing accessor and resolver namesjava.lang.Exception - if accessor or resolver can't be instantiatedpublic boolean beginIteration()
throws java.lang.Exception
beginIteration in interface Bridgejava.lang.Exceptionpublic Writable getNext() throws java.lang.Exception
public static ReadAccessor getFileAccessor(InputData inputData) throws java.lang.Exception
java.lang.Exceptionpublic static ReadResolver getFieldsResolver(InputData inputData) throws java.lang.Exception
java.lang.Exceptionpublic boolean setNext(java.io.DataInputStream inputStream)
public boolean isThreadSafe()
isThreadSafe in interface Bridge