com.streambase.sb.client

Class StreamBaseClient.TupleBuffer

java.lang.Object

com.streambase.sb.client.StreamBaseClient.TupleBuffer

Direct Known Subclasses:

StreamBaseClient.SerializedTupleBuffer

Enclosing class:

StreamBaseClient

public abstract class StreamBaseClient.TupleBuffer
extends Object

Class for abstracting away where tuples come from, Buffers, Collections, and Single Enqueues.

Method Summary

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(Object obj)
int	hashCode()
StreamProperties	props() get stream properties for this Buffer
int	tupleCount()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Method Detail

addToBuffer

protected abstract void addToBuffer(Tuple tuple,
                                    int id)
                             throws TupleException

Throws:

TupleException

props

public StreamProperties props()

get stream properties for this Buffer

Returns:

stream properties for the buffer

checkTuple

protected void checkTuple(Tuple tuple)

Check tuple to make sure it is up to snuff

Parameters:

tuple -

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

tupleCount

public int tupleCount()

canEnqueue

public boolean canEnqueue(StreamProperties props)

canDequeue

public boolean canDequeue(StreamProperties props)