Class DistributeMemberInfo
-
- 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 DistributeMemberInfo extends SpecificRecordBase implements SpecificRecord
Distribute an updated member info to the rest of the network.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public class
DistributeMemberInfo.Builder
RecordBuilder for DistributeMemberInfo instances.
-
Field Summary
Fields Modifier and Type Field Description public final static Schema
SCHEMA$
public HoldingIdentity
mgm
public HoldingIdentity
updatedMember
public Integer
minimumGroupParametersEpoch
public Long
minimumUpdatedMemberSerial
-
Constructor Summary
Constructors Constructor Description DistributeMemberInfo()
Default constructor. DistributeMemberInfo(HoldingIdentity mgm, HoldingIdentity updatedMember, Integer minimumGroupParametersEpoch, Long minimumUpdatedMemberSerial)
All-args constructor.
-
Method Summary
Modifier and Type Method Description HoldingIdentity
getMgm()
Gets the value of the 'mgm' field. void
setMgm(HoldingIdentity value)
Sets the value of the 'mgm' field. HoldingIdentity
getUpdatedMember()
Gets the value of the 'updatedMember' field. void
setUpdatedMember(HoldingIdentity value)
Sets the value of the 'updatedMember' field. Integer
getMinimumGroupParametersEpoch()
Gets the value of the 'minimumGroupParametersEpoch' field. void
setMinimumGroupParametersEpoch(Integer value)
Sets the value of the 'minimumGroupParametersEpoch' field. Long
getMinimumUpdatedMemberSerial()
Gets the value of the 'minimumUpdatedMemberSerial' field. void
setMinimumUpdatedMemberSerial(Long value)
Sets the value of the 'minimumUpdatedMemberSerial' field. static Schema
getClassSchema()
static BinaryMessageEncoder<DistributeMemberInfo>
getEncoder()
Return the BinaryMessageEncoder instance used by this class. static BinaryMessageDecoder<DistributeMemberInfo>
getDecoder()
Return the BinaryMessageDecoder instance used by this class. static BinaryMessageDecoder<DistributeMemberInfo>
createDecoder(SchemaStore resolver)
Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore. ByteBuffer
toByteBuffer()
Serializes this DistributeMemberInfo to a ByteBuffer. static DistributeMemberInfo
fromByteBuffer(ByteBuffer b)
Deserializes a DistributeMemberInfo from a ByteBuffer. SpecificData
getSpecificData()
Schema
getSchema()
Object
get(int field$)
void
put(int field$, Object value$)
static DistributeMemberInfo.Builder
newBuilder()
Creates a new DistributeMemberInfo RecordBuilder. static DistributeMemberInfo.Builder
newBuilder(DistributeMemberInfo.Builder other)
Creates a new DistributeMemberInfo RecordBuilder by copying an existing Builder. static DistributeMemberInfo.Builder
newBuilder(DistributeMemberInfo other)
Creates a new DistributeMemberInfo RecordBuilder by copying an existing DistributeMemberInfo instance. void
writeExternal(ObjectOutput out)
void
readExternal(ObjectInput in)
void
customEncode(Encoder out)
void
customDecode(ResolvingDecoder in)
-
Methods inherited from class org.apache.avro.specific.SpecificRecordBase
compareTo, 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
-
DistributeMemberInfo
DistributeMemberInfo()
Default constructor.
-
DistributeMemberInfo
DistributeMemberInfo(HoldingIdentity mgm, HoldingIdentity updatedMember, Integer minimumGroupParametersEpoch, Long minimumUpdatedMemberSerial)
All-args constructor.- Parameters:
mgm
- The membership group manager of the group.updatedMember
- The member which has been updated.minimumGroupParametersEpoch
- The minimum group parameter epoch to be distribute (if null we use the latest version).minimumUpdatedMemberSerial
- The serial number of the minimum version of the updated members' memberInfo to distribute (if null we use the latest version).
-
-
Method Detail
-
getMgm
HoldingIdentity getMgm()
Gets the value of the 'mgm' field.
-
setMgm
void setMgm(HoldingIdentity value)
Sets the value of the 'mgm' field. The membership group manager of the group.
- Parameters:
value
- the value to set.
-
getUpdatedMember
HoldingIdentity getUpdatedMember()
Gets the value of the 'updatedMember' field.
-
setUpdatedMember
void setUpdatedMember(HoldingIdentity value)
Sets the value of the 'updatedMember' field. The member which has been updated.
- Parameters:
value
- the value to set.
-
getMinimumGroupParametersEpoch
Integer getMinimumGroupParametersEpoch()
Gets the value of the 'minimumGroupParametersEpoch' field.
-
setMinimumGroupParametersEpoch
void setMinimumGroupParametersEpoch(Integer value)
Sets the value of the 'minimumGroupParametersEpoch' field. The minimum group parameter epoch to be distribute (if null we use the latest version). If the group parameters with this epoch hasn't been published, then the membership actions processor will requeue this request to retry later.
- Parameters:
value
- the value to set.
-
getMinimumUpdatedMemberSerial
Long getMinimumUpdatedMemberSerial()
Gets the value of the 'minimumUpdatedMemberSerial' field.
-
setMinimumUpdatedMemberSerial
void setMinimumUpdatedMemberSerial(Long value)
Sets the value of the 'minimumUpdatedMemberSerial' field. The serial number of the minimum version of the updated members' memberInfo to distribute (if null we use the latest version). If the member info with this serial hasn't been published, then the membership actions processor will requeue this request to retry later.
- Parameters:
value
- the value to set.
-
getClassSchema
static Schema getClassSchema()
-
getEncoder
static BinaryMessageEncoder<DistributeMemberInfo> getEncoder()
Return the BinaryMessageEncoder instance used by this class.
-
getDecoder
static BinaryMessageDecoder<DistributeMemberInfo> getDecoder()
Return the BinaryMessageDecoder instance used by this class.
-
createDecoder
static BinaryMessageDecoder<DistributeMemberInfo> 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 DistributeMemberInfo to a ByteBuffer.
-
fromByteBuffer
static DistributeMemberInfo fromByteBuffer(ByteBuffer b)
Deserializes a DistributeMemberInfo 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 DistributeMemberInfo.Builder newBuilder()
Creates a new DistributeMemberInfo RecordBuilder.
-
newBuilder
static DistributeMemberInfo.Builder newBuilder(DistributeMemberInfo.Builder other)
Creates a new DistributeMemberInfo RecordBuilder by copying an existing Builder.
- Parameters:
other
- The existing builder to copy.
-
newBuilder
static DistributeMemberInfo.Builder newBuilder(DistributeMemberInfo other)
Creates a new DistributeMemberInfo RecordBuilder by copying an existing DistributeMemberInfo instance.
- Parameters:
other
- The existing instance to copy.
-
writeExternal
void writeExternal(ObjectOutput out)
-
readExternal
void readExternal(ObjectInput in)
-
customEncode
void customEncode(Encoder out)
-
customDecode
void customDecode(ResolvingDecoder in)
-
-
-
-