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 Bridge
java.lang.Exception
public Writable getNext() throws java.lang.Exception
public static ReadAccessor getFileAccessor(InputData inputData) throws java.lang.Exception
java.lang.Exception
public static ReadResolver getFieldsResolver(InputData inputData) throws java.lang.Exception
java.lang.Exception
public boolean setNext(java.io.DataInputStream inputStream)
public boolean isThreadSafe()
isThreadSafe
in interface Bridge