com.scaleoutsoftware.soss.hserver.interop

Class ObjectReader

java.lang.Object

com.scaleoutsoftware.soss.hserver.interop.ObjectReader

All Implemented Interfaces:

Closeable, AutoCloseable

public abstract class ObjectReader
extends Object
implements Closeable

This class optimizes sequential reads by reusing an underlying buffer. It is not designed to be used by several threads asynchronously. This class will substitute the underlying buffer with a new one if the buffer is too small to contain an object.

Constructor Summary

Constructors

Constructor and Description
ObjectReader()

Method Summary

Modifier and Type	Method and Description
byte[]	getBuffer() Gets the underlying buffer.
int	getLength() Gets the length of the last read object.
abstract void	read(com.scaleoutsoftware.soss.client.da.StateServerKey key) Gets an object from the ScaleOut StateServer store based on the object key.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.io.Closeable

close

Constructor Detail

ObjectReader

public ObjectReader()

Method Detail

read

public abstract void read(com.scaleoutsoftware.soss.client.da.StateServerKey key)
                   throws com.scaleoutsoftware.soss.client.da.StateServerException

Gets an object from the ScaleOut StateServer store based on the object key. The object data is stored in the buffer and can be retrieved with getBuffer().

Parameters:

key - object key

Throws:

com.scaleoutsoftware.soss.client.da.StateServerException - If there was a communication error between the JVM and ScaleOut StateServer (or if ScaleOut StateServer experienced an internal error)

getBuffer

public byte[] getBuffer()

Gets the underlying buffer.

Returns:

byte buffer containing the object

getLength

public int getLength()

Gets the length of the last read object.

Returns:

length of the object