Class PushJobDetailsStatusTuple
- java.lang.Object
-
- org.apache.avro.specific.SpecificRecordBase
-
- com.linkedin.venice.status.protocol.PushJobDetailsStatusTuple
-
- 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 PushJobDetailsStatusTuple extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord
0 => STARTED, 1 => COMPLETED, 2 => ERROR, 3 => NOT_CREATED, 4 => UNKNOWN, 5 => TOPIC_CREATED, 6 => WRITE_TO_KAFKA_COMPLETED, 7 => KILLED, 8 => END_OF_PUSH_RECEIVED, 9 => START_OF_INCREMENTAL_PUSH_RECEIVED, 10 => END_OF_INCREMENTAL_PUSH_RECEIVED- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description PushJobDetailsStatusTuple()
Default constructor.PushJobDetailsStatusTuple(java.lang.Integer status, java.lang.Long timestamp)
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()
org.apache.avro.Schema
getSchema()
org.apache.avro.specific.SpecificData
getSpecificData()
int
getStatus()
Gets the value of the 'status' field.long
getTimestamp()
Gets the value of the 'timestamp' field.void
put(int field$, java.lang.Object value$)
void
readExternal(java.io.ObjectInput in)
void
setStatus(int value)
Sets the value of the 'status' field.void
setTimestamp(long value)
Sets the value of the 'timestamp' 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
-
-
-
-
Constructor Detail
-
PushJobDetailsStatusTuple
public PushJobDetailsStatusTuple()
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should usenewBuilder()
.
-
PushJobDetailsStatusTuple
public PushJobDetailsStatusTuple(java.lang.Integer status, java.lang.Long timestamp)
All-args constructor.- Parameters:
status
- The new value for statustimestamp
- The new value for timestamp
-
-
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
-
getStatus
public int getStatus()
Gets the value of the 'status' field.- Returns:
- The value of the 'status' field.
-
setStatus
public void setStatus(int value)
Sets the value of the 'status' field.- Parameters:
value
- the value to set.
-
getTimestamp
public long getTimestamp()
Gets the value of the 'timestamp' field.- Returns:
- The value of the 'timestamp' field.
-
setTimestamp
public void setTimestamp(long value)
Sets the value of the 'timestamp' 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
-
-