Package com.streambase.sb.client

Class StreamBaseClient.SerializedTupleBuffer

java.lang.Object

com.streambase.sb.client.StreamBaseClient.TupleBuffer

com.streambase.sb.client.StreamBaseClient.SerializedTupleBuffer

Enclosing class:

StreamBaseClient

public class StreamBaseClient.SerializedTupleBuffer
extends StreamBaseClient.TupleBuffer

A TupleBuffer which contains a byte buffer of serialized tuples including space for a network header

Method Summary

Modifier and Type	Method	Description
protected void	addToBuffer(Tuple tuple, int id)	Possibly add a tuple if there is room
ByteBuffer	getBuffer()	Return a ByteBuffer containing all of the tuples ready to be serialized also contains empty space at the beginning of the buffer for a network header

Methods inherited from class com.streambase.sb.client.StreamBaseClient.TupleBuffer

canDequeue, canEnqueue, checkTuple, equals, hashCode, props, tupleCount

Methods inherited from class java.lang.Object

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

Method Details

addToBuffer

protected void addToBuffer(Tuple tuple,
 int id)
                    throws TupleException

Possibly add a tuple if there is room

Specified by:

addToBuffer in class StreamBaseClient.TupleBuffer

Parameters:

tuple - tuple to add

id - tuple identifier

Throws:

TupleException - Error adding to buffer

getBuffer

public ByteBuffer getBuffer()

Return a ByteBuffer containing all of the tuples ready to be serialized also contains empty space at the beginning of the buffer for a network header

Returns:

byteBuffer containing serialized headers including empty space in the beginning for a network header