org.apache.hawq.pxf.service

Class BridgeOutputBuilder

java.lang.Object

org.apache.hawq.pxf.service.BridgeOutputBuilder

public class BridgeOutputBuilder
extends java.lang.Object

Class creates the output record that is piped by the java process to the HAWQ backend. Actually, the output record is serialized and the obtained byte string is piped to the HAWQ segment. The output record will implement Writable, and the mission of BridgeOutputBuilder will be to translate a list of OneField objects (obtained from the Resolver) into an output record.

Constructor Summary

Constructors

Constructor and Description
BridgeOutputBuilder(ProtocolData input) Constructs a BridgeOutputBuilder.

Method Summary

Modifier and Type	Method and Description
Writable	getErrorOutput(java.lang.Exception ex) Returns the error record.
Writable	getPartialLine() Returns whether or not this is a partial line.
java.util.LinkedList<Writable>	makeOutput(java.util.List<OneField> recFields) Translates recFields (obtained from the Resolver) into an output record.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BridgeOutputBuilder

public BridgeOutputBuilder(ProtocolData input)

Constructs a BridgeOutputBuilder.

Parameters:

input - input data, like requested output format and schema information

Method Detail

getErrorOutput

public Writable getErrorOutput(java.lang.Exception ex)
                        throws java.lang.Exception

Returns the error record. If the output format is not binary, error records are not supported, and the given exception will be thrown

Parameters:

ex - exception to be stored in record

Returns:

error record

Throws:

java.lang.Exception - if the output format is not binary

makeOutput

public java.util.LinkedList<Writable> makeOutput(java.util.List<OneField> recFields)
                                          throws BadRecordException

Translates recFields (obtained from the Resolver) into an output record.

Parameters:

recFields - record fields to be serialized

Returns:

list of Writable objects with serialized row

Throws:

BadRecordException - if building the output record failed

getPartialLine

public Writable getPartialLine()

Returns whether or not this is a partial line.

Returns:

true for a partial line