public abstract class StreamBaseClient.TupleBuffer
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
protected abstract void |
addToBuffer(Tuple tuple,
int id) |
boolean |
canDequeue(StreamProperties props) |
boolean |
canEnqueue(StreamProperties props) |
protected void |
checkTuple(Tuple tuple)
Check tuple to make sure it is up to snuff
|
boolean |
equals(java.lang.Object obj) |
int |
hashCode() |
StreamProperties |
props()
get stream properties for this Buffer
|
int |
tupleCount() |
protected abstract void addToBuffer(Tuple tuple, int id) throws TupleException
TupleException
public StreamProperties props()
protected void checkTuple(Tuple tuple)
tuple
- public boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public int tupleCount()
public boolean canEnqueue(StreamProperties props)
public boolean canDequeue(StreamProperties props)