Class IngestionTaskReport
- java.lang.Object
-
- org.apache.avro.specific.SpecificRecordBase
-
- com.linkedin.venice.ingestion.protocol.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
int
leaderFollowerState
java.lang.CharSequence
message
long
offset
java.util.List<java.nio.ByteBuffer>
offsetRecordArray
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 => Stoppedstatic 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.util.List<java.nio.ByteBuffer> offsetRecordArray, java.nio.ByteBuffer storeVersionState, java.lang.Integer leaderFollowerState)
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.int
getLeaderFollowerState()
Gets the value of the 'leaderFollowerState' field.java.lang.CharSequence
getMessage()
Gets the value of the 'message' field.long
getOffset()
Gets the value of the 'offset' field.java.util.List<java.nio.ByteBuffer>
getOffsetRecordArray()
Gets the value of the 'offsetRecordArray' 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
setLeaderFollowerState(int value)
Sets the value of the 'leaderFollowerState' 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
setOffsetRecordArray(java.util.List<java.nio.ByteBuffer> value)
Sets the value of the 'offsetRecordArray' 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
-
-
-
-
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
-
offsetRecordArray
public java.util.List<java.nio.ByteBuffer> offsetRecordArray
-
storeVersionState
public java.nio.ByteBuffer storeVersionState
-
leaderFollowerState
public int leaderFollowerState
-
-
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 usenewBuilder()
.
-
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.util.List<java.nio.ByteBuffer> offsetRecordArray, java.nio.ByteBuffer storeVersionState, java.lang.Integer leaderFollowerState)
All-args constructor.- Parameters:
topicName
- The new value for topicNamepartitionId
- The new value for partitionIdoffset
- The new value for offsetisPositive
- The new value for isPositiveexceptionThrown
- The new value for exceptionThrownreportType
- 0 => Completed, 1=> Errored, 2 => Started, 3 => Restarted, 4 => Progress, 5 => EndOfPushReceived, 6 => StartOfBufferReplayReceived, 7 => StartOfIncrementalPushReceived, 8 => EndOfIncrementalPushReceived, 9 => TopicSwitchReceived, 10 => DataRecoveryCompleted, 11 => Stoppedmessage
- The new value for messageoffsetRecordArray
- The new value for offsetRecordArraystoreVersionState
- The new value for storeVersionStateleaderFollowerState
- The new value for leaderFollowerState
-
-
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
-
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.
-
getOffsetRecordArray
public java.util.List<java.nio.ByteBuffer> getOffsetRecordArray()
Gets the value of the 'offsetRecordArray' field.- Returns:
- The value of the 'offsetRecordArray' field.
-
setOffsetRecordArray
public void setOffsetRecordArray(java.util.List<java.nio.ByteBuffer> value)
Sets the value of the 'offsetRecordArray' 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.
-
getLeaderFollowerState
public int getLeaderFollowerState()
Gets the value of the 'leaderFollowerState' field.- Returns:
- The value of the 'leaderFollowerState' field.
-
setLeaderFollowerState
public void setLeaderFollowerState(int value)
Sets the value of the 'leaderFollowerState' field.- 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
-
-