Package com.streambase.sb.client
Class StreamBaseClient.TupleBuffer
java.lang.Object
com.streambase.sb.client.StreamBaseClient.TupleBuffer
- Direct Known Subclasses:
StreamBaseClient.SerializedTupleBuffer
- Enclosing class:
StreamBaseClient
Class for abstracting away where tuples come from, Buffers, Collections, and Single Enqueues.
-
Method Summary
Modifier and TypeMethodDescriptionprotected abstract void
addToBuffer
(Tuple tuple, int id) Add to bufferboolean
canDequeue
(StreamProperties props) Can dequeue?boolean
canEnqueue
(StreamProperties props) Can enqueue?protected void
checkTuple
(Tuple tuple) Check tuple to make sure it is up to snuffboolean
int
hashCode()
props()
get stream properties for this Bufferint
Get tuple count
-
Method Details
-
addToBuffer
Add to buffer- Parameters:
tuple
- Tuple to addid
- Identifier- Throws:
TupleException
- Error adding to buffer
-
props
get stream properties for this Buffer- Returns:
- stream properties for the buffer
-
checkTuple
Check tuple to make sure it is up to snuff- Parameters:
tuple
- tuple to check
-
equals
-
hashCode
-
tupleCount
public int tupleCount()Get tuple count- Returns:
- Number of tuples
-
canEnqueue
Can enqueue?- Parameters:
props
- Properties- Returns:
- true if can enqueue, false otherwise
-
canDequeue
Can dequeue?- Parameters:
props
- Properties- Returns:
- true if can dequeue, false otherwise
-