com.streambase.sb.client
Class StreamBaseClient.TupleBuffer

java.lang.Object
  com.streambase.sb.client.StreamBaseClient.TupleBuffer

Enclosing class:

StreamBaseClient

public abstract class StreamBaseClient.TupleBuffer
extends Object

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

Method Summary

protected void	checkTuple(Tuple tuple) Check tuple to make sure it is up to snuff
abstract int	currentSize() Get current size of this buffer
boolean	equals(Object obj)
abstract int	getDataLength()
int	hashCode()
StreamProperties	props() get stream properties for this Buffer
abstract void	storeData(ByteBuffer byteBuffer)

Methods inherited from class java.lang.Object

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

Method Detail

currentSize

public abstract int currentSize()

Get current size of this buffer

Returns:

current size of the buffer

getDataLength

public abstract int getDataLength()

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

storeData

public abstract void storeData(ByteBuffer byteBuffer)