Class ProcessMembershipUpdates
-
- All Implemented Interfaces:
-
java.io.Externalizable
,java.io.Serializable
,java.lang.Comparable
,org.apache.avro.generic.GenericContainer
,org.apache.avro.generic.GenericRecord
,org.apache.avro.generic.IndexedRecord
,org.apache.avro.specific.SpecificRecord
public class ProcessMembershipUpdates extends SpecificRecordBase implements SpecificRecord
Command issued for a member to process the membership updates sent by the MGM.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public class
ProcessMembershipUpdates.Builder
RecordBuilder for ProcessMembershipUpdates instances.
-
Field Summary
Fields Modifier and Type Field Description public final static Schema
SCHEMA$
public SynchronisationMetaData
synchronisationMetaData
public MembershipPackage
membershipPackage
-
Constructor Summary
Constructors Constructor Description ProcessMembershipUpdates()
Default constructor. ProcessMembershipUpdates(SynchronisationMetaData synchronisationMetaData, MembershipPackage membershipPackage)
All-args constructor.
-
Method Summary
Modifier and Type Method Description SynchronisationMetaData
getSynchronisationMetaData()
Gets the value of the 'synchronisationMetaData' field. void
setSynchronisationMetaData(SynchronisationMetaData value)
Sets the value of the 'synchronisationMetaData' field. MembershipPackage
getMembershipPackage()
Gets the value of the 'membershipPackage' field. void
setMembershipPackage(MembershipPackage value)
Sets the value of the 'membershipPackage' field. static Schema
getClassSchema()
static BinaryMessageEncoder<ProcessMembershipUpdates>
getEncoder()
Return the BinaryMessageEncoder instance used by this class. static BinaryMessageDecoder<ProcessMembershipUpdates>
getDecoder()
Return the BinaryMessageDecoder instance used by this class. static BinaryMessageDecoder<ProcessMembershipUpdates>
createDecoder(SchemaStore resolver)
Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore. ByteBuffer
toByteBuffer()
Serializes this ProcessMembershipUpdates to a ByteBuffer. static ProcessMembershipUpdates
fromByteBuffer(ByteBuffer b)
Deserializes a ProcessMembershipUpdates from a ByteBuffer. SpecificData
getSpecificData()
Schema
getSchema()
Object
get(int field$)
void
put(int field$, Object value$)
static ProcessMembershipUpdates.Builder
newBuilder()
Creates a new ProcessMembershipUpdates RecordBuilder. static ProcessMembershipUpdates.Builder
newBuilder(ProcessMembershipUpdates.Builder other)
Creates a new ProcessMembershipUpdates RecordBuilder by copying an existing Builder. static ProcessMembershipUpdates.Builder
newBuilder(ProcessMembershipUpdates other)
Creates a new ProcessMembershipUpdates RecordBuilder by copying an existing ProcessMembershipUpdates instance. void
writeExternal(ObjectOutput out)
void
readExternal(ObjectInput in)
-
Methods inherited from class org.apache.avro.specific.SpecificRecordBase
compareTo, customDecode, customEncode, equals, getConversion, hashCode, toString
-
Methods inherited from class org.apache.avro.generic.GenericRecord
hasField
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
Constructor Detail
-
ProcessMembershipUpdates
ProcessMembershipUpdates()
Default constructor.
-
ProcessMembershipUpdates
ProcessMembershipUpdates(SynchronisationMetaData synchronisationMetaData, MembershipPackage membershipPackage)
All-args constructor.- Parameters:
synchronisationMetaData
- Data used for processing synchronisation commands.membershipPackage
- Data package distributed by the MGM containing membership updates.
-
-
Method Detail
-
getSynchronisationMetaData
SynchronisationMetaData getSynchronisationMetaData()
Gets the value of the 'synchronisationMetaData' field.
-
setSynchronisationMetaData
void setSynchronisationMetaData(SynchronisationMetaData value)
Sets the value of the 'synchronisationMetaData' field. Data used for processing synchronisation commands.
- Parameters:
value
- the value to set.
-
getMembershipPackage
MembershipPackage getMembershipPackage()
Gets the value of the 'membershipPackage' field.
-
setMembershipPackage
void setMembershipPackage(MembershipPackage value)
Sets the value of the 'membershipPackage' field. Data package distributed by the MGM containing membership updates.
- Parameters:
value
- the value to set.
-
getClassSchema
static Schema getClassSchema()
-
getEncoder
static BinaryMessageEncoder<ProcessMembershipUpdates> getEncoder()
Return the BinaryMessageEncoder instance used by this class.
-
getDecoder
static BinaryMessageDecoder<ProcessMembershipUpdates> getDecoder()
Return the BinaryMessageDecoder instance used by this class.
-
createDecoder
static BinaryMessageDecoder<ProcessMembershipUpdates> createDecoder(SchemaStore resolver)
Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore.
- Parameters:
resolver
- a SchemaStore used to find schemas by fingerprint
-
toByteBuffer
ByteBuffer toByteBuffer()
Serializes this ProcessMembershipUpdates to a ByteBuffer.
-
fromByteBuffer
static ProcessMembershipUpdates fromByteBuffer(ByteBuffer b)
Deserializes a ProcessMembershipUpdates from a ByteBuffer.
- Parameters:
b
- a byte buffer holding serialized data for an instance of this class
-
getSpecificData
SpecificData getSpecificData()
-
getSchema
Schema getSchema()
-
newBuilder
static ProcessMembershipUpdates.Builder newBuilder()
Creates a new ProcessMembershipUpdates RecordBuilder.
-
newBuilder
static ProcessMembershipUpdates.Builder newBuilder(ProcessMembershipUpdates.Builder other)
Creates a new ProcessMembershipUpdates RecordBuilder by copying an existing Builder.
- Parameters:
other
- The existing builder to copy.
-
newBuilder
static ProcessMembershipUpdates.Builder newBuilder(ProcessMembershipUpdates other)
Creates a new ProcessMembershipUpdates RecordBuilder by copying an existing ProcessMembershipUpdates instance.
- Parameters:
other
- The existing instance to copy.
-
writeExternal
void writeExternal(ObjectOutput out)
-
readExternal
void readExternal(ObjectInput in)
-
-
-
-