org.teiid.query

Interface ReplicatedObject<K extends Serializable>

All Known Implementing Classes:

BufferManagerImpl, GlobalTableStoreImpl

public interface ReplicatedObject<K extends Serializable>

Optional interface to be implemented by a replicated object to support full and partial state transfer.

Method Summary

Modifier and Type	Method and Description
void	droppedMembers(Collection<Serializable> addresses) Called when members are dropped
void	getState(K state_id, OutputStream ostream) Allows an application to write a partial state through a provided OutputStream.
void	getState(OutputStream ostream) Allows an application to write a state through a provided OutputStream.
boolean	hasState(K state_id) Return true if the object has the given state
void	setAddress(Serializable address) Allows the replicator to set the local address from the channel
void	setState(InputStream istream) Allows an application to read a state through a provided InputStream.
void	setState(K state_id, InputStream istream) Allows an application to read a partial state through a provided InputStream.

Method Detail

getState

void getState(OutputStream ostream)

Allows an application to write a state through a provided OutputStream.

Parameters:

ostream - the OutputStream

getState

void getState(K state_id,
              OutputStream ostream)

Allows an application to write a partial state through a provided OutputStream.

Parameters:

state_id - id of the partial state requested

ostream - the OutputStream

setState

void setState(InputStream istream)

Allows an application to read a state through a provided InputStream.

Parameters:

istream - the InputStream

setState

void setState(K state_id,
              InputStream istream)

Allows an application to read a partial state through a provided InputStream.

Parameters:

state_id - id of the partial state requested

istream - the InputStream

setAddress

void setAddress(Serializable address)

Allows the replicator to set the local address from the channel

Parameters:

address -

droppedMembers

void droppedMembers(Collection<Serializable> addresses)

Called when members are dropped

Parameters:

addresses -

hasState

boolean hasState(K state_id)

Return true if the object has the given state

Parameters:

state_id -

Returns: