public class StreamBaseClient.SerializedTupleBuffer extends StreamBaseClient.TupleBuffer
Modifier and Type | Method and Description |
---|---|
protected void |
addToBuffer(Tuple tuple,
int id)
Possibly add a tuple if there is room
|
java.nio.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
|
canDequeue, canEnqueue, checkTuple, equals, hashCode, props, tupleCount
protected void addToBuffer(Tuple tuple, int id) throws TupleException
addToBuffer
in class StreamBaseClient.TupleBuffer
tuple
- id
- TupleException
public java.nio.ByteBuffer getBuffer()