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
A TupleBuffer which contains a byte buffer of serialized tuples
including space for a network header
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
addToBuffer
(Tuple tuple, int id) Possibly add a tuple if there is roomReturn a ByteBuffer containing all of the tuples ready to be serialized also contains empty space at the beginning of the buffer for a network headerMethods inherited from class com.streambase.sb.client.StreamBaseClient.TupleBuffer
canDequeue, canEnqueue, checkTuple, equals, hashCode, props, tupleCount
-
Method Details
-
addToBuffer
Possibly add a tuple if there is room- Specified by:
addToBuffer
in classStreamBaseClient.TupleBuffer
- Parameters:
tuple
- tuple to addid
- tuple identifier- Throws:
TupleException
- Error adding to buffer
-
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
-