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 void
droppedMembers(Collection<Serializable> addresses)
Called when members are droppedvoid
getState(OutputStream ostream)
Allows an application to write a state through a provided OutputStream.void
getState(K state_id, OutputStream ostream)
Allows an application to write a partial state through a provided OutputStream.boolean
hasState(K state_id)
Return true if the object has the given statevoid
setAddress(Serializable address)
Allows the replicator to set the local address from the channelvoid
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 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:
-
-