org.apache.hawq.pxf.service.io

Class BufferWritable

java.lang.Object

org.apache.hawq.pxf.service.io.BufferWritable

All Implemented Interfaces:

Writable

public class BufferWritable
extends java.lang.Object
implements Writable

A serializable object for transporting a byte array through the Bridge framework

Constructor Summary

Constructors

Constructor and Description
BufferWritable(byte[] inBuf) Constructs a BufferWritable.

Method Summary

Modifier and Type	Method and Description
void	append(byte[] app) Appends given app's buffer to existing buffer.
void	readFields(java.io.DataInput in) Deserializes the fields of this object from in.
void	write(java.io.DataOutput out) Serializes the fields of this object to out.

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferWritable

public BufferWritable(byte[] inBuf)

Constructs a BufferWritable. Copies the buffer reference and not the actual bytes. This class is used when we intend to transport a buffer through the Bridge framework without copying the data each time the buffer is passed between the Bridge objects.

Parameters:

inBuf - buffer

Method Detail

write

public void write(java.io.DataOutput out)
           throws java.io.IOException

Serializes the fields of this object to out.

Specified by:

write in interface Writable

Parameters:

out - DataOutput to serialize this object into.

Throws:

java.io.IOException - if the buffer was not set

readFields

public void readFields(java.io.DataInput in)

Deserializes the fields of this object from in.

For efficiency, implementations should attempt to re-use storage in the existing object where possible.

Specified by:

readFields in interface Writable

Parameters:

in - DataInput to deserialize this object from

Throws:

java.lang.UnsupportedOperationException - this function is not supported

append

public void append(byte[] app)

Appends given app's buffer to existing buffer.
Not efficient - requires copying both this and the appended buffer.

Parameters:

app - buffer to append