Package 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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voiddroppedMembers(Collection<Serializable> addresses)Called when members are droppedvoidgetState(OutputStream ostream)Allows an application to write a state through a provided OutputStream.voidgetState(K state_id, OutputStream ostream)Allows an application to write a partial state through a provided OutputStream.booleanhasState(K state_id)Return true if the object has the given statevoidsetAddress(Serializable address)Allows the replicator to set the local address from the channelvoidsetState(InputStream istream)Allows an application to read a state through a provided InputStream.voidsetState(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 requestedostream- 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 requestedistream- 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:
-
-