Package com.linkedin.venice.controller.kafka.protocol.admin

Class AdminOperation

java.lang.Object
org.apache.avro.specific.SpecificRecordBase
com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation
All Implemented Interfaces:
Externalizable, Serializable, 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 AdminOperation extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord
See Also:

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    long
    executionId
    ID of a command execution which is used to query the status of this command.
    int
    operationType
    0 => StoreCreation, 1 => ValueSchemaCreation, 2 => PauseStore, 3 => ResumeStore, 4 => KillOfflinePushJob, 5 => DisableStoreRead, 6 => EnableStoreRead, 7=> DeleteAllVersions, 8=> SetStoreOwner, 9=> SetStorePartitionCount, 10=> SetStoreCurrentVersion, 11=> UpdateStore, 12=> DeleteStore, 13=> DeleteOldVersion, 14=> MigrateStore, 15=> AbortMigration, 16=>AddVersion, 17=> DerivedSchemaCreation, 18=>SupersetSchemaCreation, 19=>EnableNativeReplicationForCluster, 20=>MetadataSchemaCreation, 21=>EnableActiveActiveReplicationForCluster, 25=>CreatePersona, 26=>DeletePersona, 27=>UpdatePersona, 28=>RollbackCurrentVersion, 29=>RollforwardCurrentVersion
    Object
    payloadUnion
    This contains the main payload of the admin operation
    static final org.apache.avro.Schema
    SCHEMA$
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    AdminOperation()
    Default constructor.
    AdminOperation(Integer operationType, Long executionId, Object payloadUnion)
    All-args constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    Object
    get(int field$)
     
    static org.apache.avro.Schema
    getClassSchema()
     
    long
    getExecutionId()
    Gets the value of the 'executionId' field.
    int
    getOperationType()
    Gets the value of the 'operationType' field.
    Object
    getPayloadUnion()
    Gets the value of the 'payloadUnion' field.
    org.apache.avro.Schema
    getSchema()
     
    org.apache.avro.specific.SpecificData
    getSpecificData()
     
    void
    put(int field$, Object value$)
     
    void
    readExternal(ObjectInput in)
     
    void
    setExecutionId(long value)
    Sets the value of the 'executionId' field.
    void
    setOperationType(int value)
    Sets the value of the 'operationType' field.
    void
    setPayloadUnion(Object value)
    Sets the value of the 'payloadUnion' field.
    void
    writeExternal(ObjectOutput out)
     

    Methods inherited from class org.apache.avro.specific.SpecificRecordBase

    compareTo, customDecode, customEncode, equals, get, getConversion, getConversion, hasCustomCoders, hashCode, put, toString

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

    Methods inherited from interface org.apache.avro.generic.GenericRecord

    hasField

  • Field Details

    • SCHEMA$

      public static final org.apache.avro.Schema SCHEMA$

    • operationType

      public int operationType
      0 => StoreCreation, 1 => ValueSchemaCreation, 2 => PauseStore, 3 => ResumeStore, 4 => KillOfflinePushJob, 5 => DisableStoreRead, 6 => EnableStoreRead, 7=> DeleteAllVersions, 8=> SetStoreOwner, 9=> SetStorePartitionCount, 10=> SetStoreCurrentVersion, 11=> UpdateStore, 12=> DeleteStore, 13=> DeleteOldVersion, 14=> MigrateStore, 15=> AbortMigration, 16=>AddVersion, 17=> DerivedSchemaCreation, 18=>SupersetSchemaCreation, 19=>EnableNativeReplicationForCluster, 20=>MetadataSchemaCreation, 21=>EnableActiveActiveReplicationForCluster, 25=>CreatePersona, 26=>DeletePersona, 27=>UpdatePersona, 28=>RollbackCurrentVersion, 29=>RollforwardCurrentVersion

    • executionId

      public long executionId
      ID of a command execution which is used to query the status of this command.

    • payloadUnion

      public Object payloadUnion
      This contains the main payload of the admin operation

  • Constructor Details

    • AdminOperation

      public AdminOperation()
      Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use newBuilder().

    • AdminOperation

      public AdminOperation(Integer operationType, Long executionId, Object payloadUnion)
      All-args constructor.
      Parameters:
      operationType - 0 => StoreCreation, 1 => ValueSchemaCreation, 2 => PauseStore, 3 => ResumeStore, 4 => KillOfflinePushJob, 5 => DisableStoreRead, 6 => EnableStoreRead, 7=> DeleteAllVersions, 8=> SetStoreOwner, 9=> SetStorePartitionCount, 10=> SetStoreCurrentVersion, 11=> UpdateStore, 12=> DeleteStore, 13=> DeleteOldVersion, 14=> MigrateStore, 15=> AbortMigration, 16=>AddVersion, 17=> DerivedSchemaCreation, 18=>SupersetSchemaCreation, 19=>EnableNativeReplicationForCluster, 20=>MetadataSchemaCreation, 21=>EnableActiveActiveReplicationForCluster, 25=>CreatePersona, 26=>DeletePersona, 27=>UpdatePersona, 28=>RollbackCurrentVersion, 29=>RollforwardCurrentVersion
      executionId - ID of a command execution which is used to query the status of this command.
      payloadUnion - This contains the main payload of the admin operation

  • Method Details

    • getClassSchema

      public static org.apache.avro.Schema getClassSchema()

    • getSpecificData

      public org.apache.avro.specific.SpecificData getSpecificData()
      Overrides:
      getSpecificData in class org.apache.avro.specific.SpecificRecordBase

    • getSchema

      public org.apache.avro.Schema getSchema()
      Specified by:
      getSchema in interface org.apache.avro.generic.GenericContainer
      Specified by:
      getSchema in class org.apache.avro.specific.SpecificRecordBase

    • get

      public Object get(int field$)
      Specified by:
      get in interface org.apache.avro.generic.IndexedRecord
      Specified by:
      get in class org.apache.avro.specific.SpecificRecordBase

    • put

      public void put(int field$, Object value$)
      Specified by:
      put in interface org.apache.avro.generic.IndexedRecord
      Specified by:
      put in class org.apache.avro.specific.SpecificRecordBase

    • getOperationType

      public int getOperationType()
      Gets the value of the 'operationType' field.
      Returns:
      0 => StoreCreation, 1 => ValueSchemaCreation, 2 => PauseStore, 3 => ResumeStore, 4 => KillOfflinePushJob, 5 => DisableStoreRead, 6 => EnableStoreRead, 7=> DeleteAllVersions, 8=> SetStoreOwner, 9=> SetStorePartitionCount, 10=> SetStoreCurrentVersion, 11=> UpdateStore, 12=> DeleteStore, 13=> DeleteOldVersion, 14=> MigrateStore, 15=> AbortMigration, 16=>AddVersion, 17=> DerivedSchemaCreation, 18=>SupersetSchemaCreation, 19=>EnableNativeReplicationForCluster, 20=>MetadataSchemaCreation, 21=>EnableActiveActiveReplicationForCluster, 25=>CreatePersona, 26=>DeletePersona, 27=>UpdatePersona, 28=>RollbackCurrentVersion, 29=>RollforwardCurrentVersion

    • setOperationType

      public void setOperationType(int value)
      Sets the value of the 'operationType' field. 0 => StoreCreation, 1 => ValueSchemaCreation, 2 => PauseStore, 3 => ResumeStore, 4 => KillOfflinePushJob, 5 => DisableStoreRead, 6 => EnableStoreRead, 7=> DeleteAllVersions, 8=> SetStoreOwner, 9=> SetStorePartitionCount, 10=> SetStoreCurrentVersion, 11=> UpdateStore, 12=> DeleteStore, 13=> DeleteOldVersion, 14=> MigrateStore, 15=> AbortMigration, 16=>AddVersion, 17=> DerivedSchemaCreation, 18=>SupersetSchemaCreation, 19=>EnableNativeReplicationForCluster, 20=>MetadataSchemaCreation, 21=>EnableActiveActiveReplicationForCluster, 25=>CreatePersona, 26=>DeletePersona, 27=>UpdatePersona, 28=>RollbackCurrentVersion, 29=>RollforwardCurrentVersion
      Parameters:
      value - the value to set.

    • getExecutionId

      public long getExecutionId()
      Gets the value of the 'executionId' field.
      Returns:
      ID of a command execution which is used to query the status of this command.

    • setExecutionId

      public void setExecutionId(long value)
      Sets the value of the 'executionId' field. ID of a command execution which is used to query the status of this command.
      Parameters:
      value - the value to set.

    • getPayloadUnion

      public Object getPayloadUnion()
      Gets the value of the 'payloadUnion' field.
      Returns:
      This contains the main payload of the admin operation

    • setPayloadUnion

      public void setPayloadUnion(Object value)
      Sets the value of the 'payloadUnion' field. This contains the main payload of the admin operation
      Parameters:
      value - the value to set.

    • writeExternal

      public void writeExternal(ObjectOutput out) throws IOException
      Specified by:
      writeExternal in interface Externalizable
      Overrides:
      writeExternal in class org.apache.avro.specific.SpecificRecordBase
      Throws:
      IOException

    • readExternal

      public void readExternal(ObjectInput in) throws IOException
      Specified by:
      readExternal in interface Externalizable
      Overrides:
      readExternal in class org.apache.avro.specific.SpecificRecordBase
      Throws:
      IOException