Class VersionProperties

  • 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 VersionProperties
    extends org.apache.avro.specific.SpecificRecordBase
    implements org.apache.avro.specific.SpecificRecord
    See Also:
    Serialized Form
    • Constructor Summary

      Constructors 
      Constructor Description
      VersionProperties()
      Default constructor.
      VersionProperties​(java.lang.Integer currentVersion, java.lang.Integer compressionStrategy, java.lang.Integer partitionCount, java.lang.CharSequence partitionerClass, java.util.Map<java.lang.CharSequence,​java.lang.CharSequence> partitionerParams, java.lang.Integer amplificationFactor)
      All-args constructor.
    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.lang.Object get​(int field$)  
      int getAmplificationFactor()
      Gets the value of the 'amplificationFactor' field.
      static org.apache.avro.Schema getClassSchema()  
      int getCompressionStrategy()
      Gets the value of the 'compressionStrategy' field.
      int getCurrentVersion()
      Gets the value of the 'currentVersion' field.
      int getPartitionCount()
      Gets the value of the 'partitionCount' field.
      java.lang.CharSequence getPartitionerClass()
      Gets the value of the 'partitionerClass' field.
      java.util.Map<java.lang.CharSequence,​java.lang.CharSequence> getPartitionerParams()
      Gets the value of the 'partitionerParams' 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 setAmplificationFactor​(int value)
      Sets the value of the 'amplificationFactor' field.
      void setCompressionStrategy​(int value)
      Sets the value of the 'compressionStrategy' field.
      void setCurrentVersion​(int value)
      Sets the value of the 'currentVersion' field.
      void setPartitionCount​(int value)
      Sets the value of the 'partitionCount' field.
      void setPartitionerClass​(java.lang.CharSequence value)
      Sets the value of the 'partitionerClass' field.
      void setPartitionerParams​(java.util.Map<java.lang.CharSequence,​java.lang.CharSequence> value)
      Sets the value of the 'partitionerParams' 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$
      • currentVersion

        public int currentVersion
        Current version number
      • compressionStrategy

        public int compressionStrategy
        The current version's compression strategy. 0 -> NO_OP, 1 -> GZIP, 2 -> ZSTD, 3 -> ZSTD_WITH_DICT
      • partitionCount

        public int partitionCount
        Partition count of the current version
      • partitionerClass

        public java.lang.CharSequence partitionerClass
        Partitioner class name
      • partitionerParams

        public java.util.Map<java.lang.CharSequence,​java.lang.CharSequence> partitionerParams
        Partitioner parameters
      • amplificationFactor

        public int amplificationFactor
        Partitioner amplification factor
    • Constructor Detail

      • VersionProperties

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

        public VersionProperties​(java.lang.Integer currentVersion,
                                 java.lang.Integer compressionStrategy,
                                 java.lang.Integer partitionCount,
                                 java.lang.CharSequence partitionerClass,
                                 java.util.Map<java.lang.CharSequence,​java.lang.CharSequence> partitionerParams,
                                 java.lang.Integer amplificationFactor)
        All-args constructor.
        Parameters:
        currentVersion - Current version number
        compressionStrategy - The current version's compression strategy. 0 -> NO_OP, 1 -> GZIP, 2 -> ZSTD, 3 -> ZSTD_WITH_DICT
        partitionCount - Partition count of the current version
        partitionerClass - Partitioner class name
        partitionerParams - Partitioner parameters
        amplificationFactor - Partitioner amplification factor
    • 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
      • getCurrentVersion

        public int getCurrentVersion()
        Gets the value of the 'currentVersion' field.
        Returns:
        Current version number
      • setCurrentVersion

        public void setCurrentVersion​(int value)
        Sets the value of the 'currentVersion' field. Current version number
        Parameters:
        value - the value to set.
      • getCompressionStrategy

        public int getCompressionStrategy()
        Gets the value of the 'compressionStrategy' field.
        Returns:
        The current version's compression strategy. 0 -> NO_OP, 1 -> GZIP, 2 -> ZSTD, 3 -> ZSTD_WITH_DICT
      • setCompressionStrategy

        public void setCompressionStrategy​(int value)
        Sets the value of the 'compressionStrategy' field. The current version's compression strategy. 0 -> NO_OP, 1 -> GZIP, 2 -> ZSTD, 3 -> ZSTD_WITH_DICT
        Parameters:
        value - the value to set.
      • getPartitionCount

        public int getPartitionCount()
        Gets the value of the 'partitionCount' field.
        Returns:
        Partition count of the current version
      • setPartitionCount

        public void setPartitionCount​(int value)
        Sets the value of the 'partitionCount' field. Partition count of the current version
        Parameters:
        value - the value to set.
      • getPartitionerClass

        public java.lang.CharSequence getPartitionerClass()
        Gets the value of the 'partitionerClass' field.
        Returns:
        Partitioner class name
      • setPartitionerClass

        public void setPartitionerClass​(java.lang.CharSequence value)
        Sets the value of the 'partitionerClass' field. Partitioner class name
        Parameters:
        value - the value to set.
      • getPartitionerParams

        public java.util.Map<java.lang.CharSequence,​java.lang.CharSequence> getPartitionerParams()
        Gets the value of the 'partitionerParams' field.
        Returns:
        Partitioner parameters
      • setPartitionerParams

        public void setPartitionerParams​(java.util.Map<java.lang.CharSequence,​java.lang.CharSequence> value)
        Sets the value of the 'partitionerParams' field. Partitioner parameters
        Parameters:
        value - the value to set.
      • getAmplificationFactor

        public int getAmplificationFactor()
        Gets the value of the 'amplificationFactor' field.
        Returns:
        Partitioner amplification factor
      • setAmplificationFactor

        public void setAmplificationFactor​(int value)
        Sets the value of the 'amplificationFactor' field. Partitioner amplification factor
        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