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

Class ConfigureIncrementalPushForCluster

  • 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 ConfigureIncrementalPushForCluster
extends org.apache.avro.specific.SpecificRecordBase
implements org.apache.avro.specific.SpecificRecord
    A command to migrate all incremental push stores in a cluster to a specific incremental push policy.
    See Also:
    Serialized Form

    • Field Summary

      Fields 
      Modifier and Type Field Description
      java.lang.CharSequence clusterName  
      int incrementalPushPolicyToApply
      This field will determine what incremental push policy will be applied to the selected stores.
      int incrementalPushPolicyToFilter
      If this batch update command is trying to configure existing incremental push store type, their incremental push policy should also match this filter before the batch update command applies any change to them.
      java.lang.CharSequence regionsFilter  
      static org.apache.avro.Schema SCHEMA$  

    • Constructor Summary

      Constructors 
      Constructor Description
      ConfigureIncrementalPushForCluster()
      Default constructor.
      ConfigureIncrementalPushForCluster​(java.lang.CharSequence clusterName, java.lang.Integer incrementalPushPolicyToFilter, java.lang.Integer incrementalPushPolicyToApply, java.lang.CharSequence regionsFilter)
      All-args constructor.

    • 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.lang.CharSequence getClusterName()
      Gets the value of the 'clusterName' field.
      int getIncrementalPushPolicyToApply()
      Gets the value of the 'incrementalPushPolicyToApply' field.
      int getIncrementalPushPolicyToFilter()
      Gets the value of the 'incrementalPushPolicyToFilter' field.
      java.lang.CharSequence getRegionsFilter()
      Gets the value of the 'regionsFilter' field.
      org.apache.avro.Schema getSchema()  
      org.apache.avro.specific.SpecificData getSpecificData()  
      void put​(int field$, java.lang.Object value$)  
      void readExternal​(java.io.ObjectInput in)  
      void setClusterName​(java.lang.CharSequence value)
      Sets the value of the 'clusterName' field.
      void setIncrementalPushPolicyToApply​(int value)
      Sets the value of the 'incrementalPushPolicyToApply' field.
      void setIncrementalPushPolicyToFilter​(int value)
      Sets the value of the 'incrementalPushPolicyToFilter' field.
      void setRegionsFilter​(java.lang.CharSequence value)
      Sets the value of the 'regionsFilter' 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

      • 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 Detail

      • SCHEMA$

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

      • clusterName

        public java.lang.CharSequence clusterName

      • incrementalPushPolicyToFilter

        public int incrementalPushPolicyToFilter
        If this batch update command is trying to configure existing incremental push store type, their incremental push policy should also match this filter before the batch update command applies any change to them. Default value is -1, meaning there is no filter.

      • incrementalPushPolicyToApply

        public int incrementalPushPolicyToApply
        This field will determine what incremental push policy will be applied to the selected stores. Default value is 1, which is the INCREMENTAL_PUSH_SAME_AS_REAL_TIME policy

      • regionsFilter

        public java.lang.CharSequence regionsFilter

    • Constructor Detail

      • ConfigureIncrementalPushForCluster

        public ConfigureIncrementalPushForCluster()
        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().

      • ConfigureIncrementalPushForCluster

        public ConfigureIncrementalPushForCluster​(java.lang.CharSequence clusterName,
                                          java.lang.Integer incrementalPushPolicyToFilter,
                                          java.lang.Integer incrementalPushPolicyToApply,
                                          java.lang.CharSequence regionsFilter)
        All-args constructor.
        Parameters:
        clusterName - The new value for clusterName
        incrementalPushPolicyToFilter - If this batch update command is trying to configure existing incremental push store type, their incremental push policy should also match this filter before the batch update command applies any change to them. Default value is -1, meaning there is no filter.
        incrementalPushPolicyToApply - This field will determine what incremental push policy will be applied to the selected stores. Default value is 1, which is the INCREMENTAL_PUSH_SAME_AS_REAL_TIME policy
        regionsFilter - The new value for regionsFilter

    • Method Detail

      • 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 java.lang.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$,
                java.lang.Object value$)
        Specified by:
        put in interface org.apache.avro.generic.IndexedRecord
        Specified by:
        put in class org.apache.avro.specific.SpecificRecordBase

      • getClusterName

        public java.lang.CharSequence getClusterName()
        Gets the value of the 'clusterName' field.
        Returns:
        The value of the 'clusterName' field.

      • setClusterName

        public void setClusterName​(java.lang.CharSequence value)
        Sets the value of the 'clusterName' field.
        Parameters:
        value - the value to set.

      • getIncrementalPushPolicyToFilter

        public int getIncrementalPushPolicyToFilter()
        Gets the value of the 'incrementalPushPolicyToFilter' field.
        Returns:
        If this batch update command is trying to configure existing incremental push store type, their incremental push policy should also match this filter before the batch update command applies any change to them. Default value is -1, meaning there is no filter.

      • setIncrementalPushPolicyToFilter

        public void setIncrementalPushPolicyToFilter​(int value)
        Sets the value of the 'incrementalPushPolicyToFilter' field. If this batch update command is trying to configure existing incremental push store type, their incremental push policy should also match this filter before the batch update command applies any change to them. Default value is -1, meaning there is no filter.
        Parameters:
        value - the value to set.

      • getIncrementalPushPolicyToApply

        public int getIncrementalPushPolicyToApply()
        Gets the value of the 'incrementalPushPolicyToApply' field.
        Returns:
        This field will determine what incremental push policy will be applied to the selected stores. Default value is 1, which is the INCREMENTAL_PUSH_SAME_AS_REAL_TIME policy

      • setIncrementalPushPolicyToApply

        public void setIncrementalPushPolicyToApply​(int value)
        Sets the value of the 'incrementalPushPolicyToApply' field. This field will determine what incremental push policy will be applied to the selected stores. Default value is 1, which is the INCREMENTAL_PUSH_SAME_AS_REAL_TIME policy
        Parameters:
        value - the value to set.

      • getRegionsFilter

        public java.lang.CharSequence getRegionsFilter()
        Gets the value of the 'regionsFilter' field.
        Returns:
        The value of the 'regionsFilter' field.

      • setRegionsFilter

        public void setRegionsFilter​(java.lang.CharSequence value)
        Sets the value of the 'regionsFilter' field.
        Parameters:
        value - the value to set.

      • writeExternal

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

      • readExternal

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