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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
addToBuffer(Tuple tuple, int id)
Possibly add a tuple if there is roomByteBuffer
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
-
-
-
-
Method Detail
-
addToBuffer
protected void addToBuffer(Tuple tuple, int id) throws TupleException
Possibly add a tuple if there is room- Specified by:
addToBuffer
in classStreamBaseClient.TupleBuffer
- Parameters:
tuple
-id
-- 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
-
-