Class Delete
- java.lang.Object
-
- org.apache.avro.specific.SpecificRecordBase
-
- com.linkedin.venice.kafka.protocol.Delete
-
- All Implemented Interfaces:
java.io.Externalizable
,java.io.Serializable
,java.lang.Comparable<org.apache.avro.specific.SpecificRecord>
,org.apache.avro.generic.GenericContainer
,org.apache.avro.generic.GenericRecord
,org.apache.avro.generic.IndexedRecord
,org.apache.avro.specific.SpecificRecord
public class Delete extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord
Delete payloads contain fields related to replication metadata of the record.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description java.nio.ByteBuffer
replicationMetadataPayload
The serialized value of the replication metadata schema.int
replicationMetadataVersionId
The A/A replication metadata schema version ID that will be used to deserialize replicationMetadataPayload.static org.apache.avro.Schema
SCHEMA$
int
schemaId
An identifier used, in conjunction with the replicationMetadataVersionId, to deserialize the replicationMetadataPayload.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Object
get(int field$)
static org.apache.avro.Schema
getClassSchema()
java.nio.ByteBuffer
getReplicationMetadataPayload()
Gets the value of the 'replicationMetadataPayload' field.int
getReplicationMetadataVersionId()
Gets the value of the 'replicationMetadataVersionId' field.org.apache.avro.Schema
getSchema()
int
getSchemaId()
Gets the value of the 'schemaId' field.org.apache.avro.specific.SpecificData
getSpecificData()
void
put(int field$, java.lang.Object value$)
void
readExternal(java.io.ObjectInput in)
void
setReplicationMetadataPayload(java.nio.ByteBuffer value)
Sets the value of the 'replicationMetadataPayload' field.void
setReplicationMetadataVersionId(int value)
Sets the value of the 'replicationMetadataVersionId' field.void
setSchemaId(int value)
Sets the value of the 'schemaId' field.void
writeExternal(java.io.ObjectOutput out)
-
Methods inherited from class org.apache.avro.specific.SpecificRecordBase
compareTo, customDecode, customEncode, equals, get, getConversion, getConversion, hasCustomCoders, hashCode, put, toString
-
-
-
-
Field Detail
-
SCHEMA$
public static final org.apache.avro.Schema SCHEMA$
-
schemaId
public int schemaId
An identifier used, in conjunction with the replicationMetadataVersionId, to deserialize the replicationMetadataPayload.
-
replicationMetadataVersionId
public int replicationMetadataVersionId
The A/A replication metadata schema version ID that will be used to deserialize replicationMetadataPayload.
-
replicationMetadataPayload
public java.nio.ByteBuffer replicationMetadataPayload
The serialized value of the replication metadata schema.
-
-
Constructor Detail
-
Delete
public Delete()
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should usenewBuilder()
.
-
Delete
public Delete(java.lang.Integer schemaId, java.lang.Integer replicationMetadataVersionId, java.nio.ByteBuffer replicationMetadataPayload)
All-args constructor.- Parameters:
schemaId
- An identifier used, in conjunction with the replicationMetadataVersionId, to deserialize the replicationMetadataPayload.replicationMetadataVersionId
- The A/A replication metadata schema version ID that will be used to deserialize replicationMetadataPayload.replicationMetadataPayload
- The serialized value of the replication metadata schema.
-
-
Method Detail
-
getClassSchema
public static org.apache.avro.Schema getClassSchema()
-
getSpecificData
public org.apache.avro.specific.SpecificData getSpecificData()
- Overrides:
getSpecificData
in classorg.apache.avro.specific.SpecificRecordBase
-
getSchema
public org.apache.avro.Schema getSchema()
- Specified by:
getSchema
in interfaceorg.apache.avro.generic.GenericContainer
- Specified by:
getSchema
in classorg.apache.avro.specific.SpecificRecordBase
-
get
public java.lang.Object get(int field$)
- Specified by:
get
in interfaceorg.apache.avro.generic.IndexedRecord
- Specified by:
get
in classorg.apache.avro.specific.SpecificRecordBase
-
put
public void put(int field$, java.lang.Object value$)
- Specified by:
put
in interfaceorg.apache.avro.generic.IndexedRecord
- Specified by:
put
in classorg.apache.avro.specific.SpecificRecordBase
-
getSchemaId
public int getSchemaId()
Gets the value of the 'schemaId' field.- Returns:
- An identifier used, in conjunction with the replicationMetadataVersionId, to deserialize the replicationMetadataPayload.
-
setSchemaId
public void setSchemaId(int value)
Sets the value of the 'schemaId' field. An identifier used, in conjunction with the replicationMetadataVersionId, to deserialize the replicationMetadataPayload.- Parameters:
value
- the value to set.
-
getReplicationMetadataVersionId
public int getReplicationMetadataVersionId()
Gets the value of the 'replicationMetadataVersionId' field.- Returns:
- The A/A replication metadata schema version ID that will be used to deserialize replicationMetadataPayload.
-
setReplicationMetadataVersionId
public void setReplicationMetadataVersionId(int value)
Sets the value of the 'replicationMetadataVersionId' field. The A/A replication metadata schema version ID that will be used to deserialize replicationMetadataPayload.- Parameters:
value
- the value to set.
-
getReplicationMetadataPayload
public java.nio.ByteBuffer getReplicationMetadataPayload()
Gets the value of the 'replicationMetadataPayload' field.- Returns:
- The serialized value of the replication metadata schema.
-
setReplicationMetadataPayload
public void setReplicationMetadataPayload(java.nio.ByteBuffer value)
Sets the value of the 'replicationMetadataPayload' field. The serialized value of the replication metadata schema.- Parameters:
value
- the value to set.
-
writeExternal
public void writeExternal(java.io.ObjectOutput out) throws java.io.IOException
- Specified by:
writeExternal
in interfacejava.io.Externalizable
- Overrides:
writeExternal
in classorg.apache.avro.specific.SpecificRecordBase
- Throws:
java.io.IOException
-
readExternal
public void readExternal(java.io.ObjectInput in) throws java.io.IOException
- Specified by:
readExternal
in interfacejava.io.Externalizable
- Overrides:
readExternal
in classorg.apache.avro.specific.SpecificRecordBase
- Throws:
java.io.IOException
-
-