Package com.linkedin.venice.ingestion.protocol

Class IngestionTaskReport

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

    • Field Summary

      Fields 
      Modifier and Type Field Description
      boolean exceptionThrown  
      boolean isPositive  
      java.lang.CharSequence message  
      long offset  
      java.nio.ByteBuffer offsetRecord  
      int partitionId  
      int reportType
      0 => Completed, 1=> Errored, 2 => Started, 3 => Restarted, 4 => Progress, 5 => EndOfPushReceived, 6 => StartOfBufferReplayReceived, 7 => StartOfIncrementalPushReceived, 8 => EndOfIncrementalPushReceived, 9 => TopicSwitchReceived, 10 => DataRecoveryCompleted, 11 => Stopped
      static org.apache.avro.Schema SCHEMA$  
      java.nio.ByteBuffer storeVersionState  
      java.lang.CharSequence topicName  

    • Constructor Summary

      Constructors 
      Constructor Description
      IngestionTaskReport()
      Default constructor.
      IngestionTaskReport​(java.lang.CharSequence topicName, java.lang.Integer partitionId, java.lang.Long offset, java.lang.Boolean isPositive, java.lang.Boolean exceptionThrown, java.lang.Integer reportType, java.lang.CharSequence message, java.nio.ByteBuffer offsetRecord, java.nio.ByteBuffer storeVersionState)
      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()  
      boolean getExceptionThrown()
      Gets the value of the 'exceptionThrown' field.
      boolean getIsPositive()
      Gets the value of the 'isPositive' field.
      java.lang.CharSequence getMessage()
      Gets the value of the 'message' field.
      long getOffset()
      Gets the value of the 'offset' field.
      java.nio.ByteBuffer getOffsetRecord()
      Gets the value of the 'offsetRecord' field.
      int getPartitionId()
      Gets the value of the 'partitionId' field.
      int getReportType()
      Gets the value of the 'reportType' field.
      org.apache.avro.Schema getSchema()  
      org.apache.avro.specific.SpecificData getSpecificData()  
      java.nio.ByteBuffer getStoreVersionState()
      Gets the value of the 'storeVersionState' field.
      java.lang.CharSequence getTopicName()
      Gets the value of the 'topicName' field.
      void put​(int field$, java.lang.Object value$)  
      void readExternal​(java.io.ObjectInput in)  
      void setExceptionThrown​(boolean value)
      Sets the value of the 'exceptionThrown' field.
      void setIsPositive​(boolean value)
      Sets the value of the 'isPositive' field.
      void setMessage​(java.lang.CharSequence value)
      Sets the value of the 'message' field.
      void setOffset​(long value)
      Sets the value of the 'offset' field.
      void setOffsetRecord​(java.nio.ByteBuffer value)
      Sets the value of the 'offsetRecord' field.
      void setPartitionId​(int value)
      Sets the value of the 'partitionId' field.
      void setReportType​(int value)
      Sets the value of the 'reportType' field.
      void setStoreVersionState​(java.nio.ByteBuffer value)
      Sets the value of the 'storeVersionState' field.
      void setTopicName​(java.lang.CharSequence value)
      Sets the value of the 'topicName' 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$

      • topicName

        public java.lang.CharSequence topicName

      • partitionId

        public int partitionId

      • offset

        public long offset

      • isPositive

        public boolean isPositive

      • exceptionThrown

        public boolean exceptionThrown

      • reportType

        public int reportType
        0 => Completed, 1=> Errored, 2 => Started, 3 => Restarted, 4 => Progress, 5 => EndOfPushReceived, 6 => StartOfBufferReplayReceived, 7 => StartOfIncrementalPushReceived, 8 => EndOfIncrementalPushReceived, 9 => TopicSwitchReceived, 10 => DataRecoveryCompleted, 11 => Stopped

      • message

        public java.lang.CharSequence message

      • offsetRecord

        public java.nio.ByteBuffer offsetRecord

      • storeVersionState

        public java.nio.ByteBuffer storeVersionState

    • Constructor Detail

      • IngestionTaskReport

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

      • IngestionTaskReport

        public IngestionTaskReport​(java.lang.CharSequence topicName,
                           java.lang.Integer partitionId,
                           java.lang.Long offset,
                           java.lang.Boolean isPositive,
                           java.lang.Boolean exceptionThrown,
                           java.lang.Integer reportType,
                           java.lang.CharSequence message,
                           java.nio.ByteBuffer offsetRecord,
                           java.nio.ByteBuffer storeVersionState)
        All-args constructor.
        Parameters:
        topicName - The new value for topicName
        partitionId - The new value for partitionId
        offset - The new value for offset
        isPositive - The new value for isPositive
        exceptionThrown - The new value for exceptionThrown
        reportType - 0 => Completed, 1=> Errored, 2 => Started, 3 => Restarted, 4 => Progress, 5 => EndOfPushReceived, 6 => StartOfBufferReplayReceived, 7 => StartOfIncrementalPushReceived, 8 => EndOfIncrementalPushReceived, 9 => TopicSwitchReceived, 10 => DataRecoveryCompleted, 11 => Stopped
        message - The new value for message
        offsetRecord - The new value for offsetRecord
        storeVersionState - The new value for storeVersionState

    • 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

      • getTopicName

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

      • setTopicName

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

      • getPartitionId

        public int getPartitionId()
        Gets the value of the 'partitionId' field.
        Returns:
        The value of the 'partitionId' field.

      • setPartitionId

        public void setPartitionId​(int value)
        Sets the value of the 'partitionId' field.
        Parameters:
        value - the value to set.

      • getOffset

        public long getOffset()
        Gets the value of the 'offset' field.
        Returns:
        The value of the 'offset' field.

      • setOffset

        public void setOffset​(long value)
        Sets the value of the 'offset' field.
        Parameters:
        value - the value to set.

      • getIsPositive

        public boolean getIsPositive()
        Gets the value of the 'isPositive' field.
        Returns:
        The value of the 'isPositive' field.

      • setIsPositive

        public void setIsPositive​(boolean value)
        Sets the value of the 'isPositive' field.
        Parameters:
        value - the value to set.

      • getExceptionThrown

        public boolean getExceptionThrown()
        Gets the value of the 'exceptionThrown' field.
        Returns:
        The value of the 'exceptionThrown' field.

      • setExceptionThrown

        public void setExceptionThrown​(boolean value)
        Sets the value of the 'exceptionThrown' field.
        Parameters:
        value - the value to set.

      • getReportType

        public int getReportType()
        Gets the value of the 'reportType' field.
        Returns:
        0 => Completed, 1=> Errored, 2 => Started, 3 => Restarted, 4 => Progress, 5 => EndOfPushReceived, 6 => StartOfBufferReplayReceived, 7 => StartOfIncrementalPushReceived, 8 => EndOfIncrementalPushReceived, 9 => TopicSwitchReceived, 10 => DataRecoveryCompleted, 11 => Stopped

      • setReportType

        public void setReportType​(int value)
        Sets the value of the 'reportType' field. 0 => Completed, 1=> Errored, 2 => Started, 3 => Restarted, 4 => Progress, 5 => EndOfPushReceived, 6 => StartOfBufferReplayReceived, 7 => StartOfIncrementalPushReceived, 8 => EndOfIncrementalPushReceived, 9 => TopicSwitchReceived, 10 => DataRecoveryCompleted, 11 => Stopped
        Parameters:
        value - the value to set.

      • getMessage

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

      • setMessage

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

      • getOffsetRecord

        public java.nio.ByteBuffer getOffsetRecord()
        Gets the value of the 'offsetRecord' field.
        Returns:
        The value of the 'offsetRecord' field.

      • setOffsetRecord

        public void setOffsetRecord​(java.nio.ByteBuffer value)
        Sets the value of the 'offsetRecord' field.
        Parameters:
        value - the value to set.

      • getStoreVersionState

        public java.nio.ByteBuffer getStoreVersionState()
        Gets the value of the 'storeVersionState' field.
        Returns:
        The value of the 'storeVersionState' field.

      • setStoreVersionState

        public void setStoreVersionState​(java.nio.ByteBuffer value)
        Sets the value of the 'storeVersionState' 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