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) Add to buffer
boolean	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 snuff
boolean	equals(Object obj)
int	hashCode()
StreamProperties	props() get stream properties for this Buffer
int	tupleCount() Get tuple count

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

Add to buffer

Parameters:

tuple - Tuple to add

id - Identifier

Throws:

TupleException - Error adding to buffer

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()

Get tuple count

Returns:

Number of tuples

canEnqueue

public boolean canEnqueue(StreamProperties props)

Can enqueue?

Parameters:

props - Properties

Returns:

true if can enqueue, false otherwise

canDequeue

public boolean canDequeue(StreamProperties props)

Can dequeue?

Parameters:

props - Properties

Returns:

true if can dequeue, false otherwise