Class PushJobDetails
- java.lang.Object
-
- org.apache.avro.specific.SpecificRecordBase
-
- com.linkedin.venice.status.protocol.PushJobDetails
-
- 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 PushJobDetails 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
chunkingEnabled
java.lang.CharSequence
clusterName
java.util.Map<java.lang.CharSequence,java.util.List<PushJobDetailsStatusTuple>>
coloStatus
java.lang.CharSequence
failureDetails
long
jobDurationInMs
java.util.List<PushJobDetailsStatusTuple>
overallStatus
int
partitionCount
java.util.Map<java.lang.CharSequence,java.lang.CharSequence>
producerConfigs
java.lang.CharSequence
pushId
java.util.Map<java.lang.CharSequence,java.lang.CharSequence>
pushJobConfigs
java.lang.Integer
pushJobLatestCheckpoint
Latest checkpoint reached by the push job if available, negative values are known error checkpoints.long
reportTimestamp
timestamp for when the reported details were collectedstatic org.apache.avro.Schema
SCHEMA$
java.lang.CharSequence
sendLivenessHeartbeatFailureDetails
Failure details of sending liveness heartbeat from the push job.long
totalCompressedValueBytes
total amount of compressed value bytes storedlong
totalGzipCompressedValueBytes
total amount of Gzip compressed value byteslong
totalKeyBytes
total amount of key bytes pushedlong
totalNumberOfRecords
total number of key value pairs pushedlong
totalRawValueBytes
total amount of uncompressed value byteslong
totalZstdWithDictCompressedValueBytes
total amount of Zstd with Dictionary compressed value bytesint
valueCompressionStrategy
0 => NO_OP, 1 => GZIP
-
Constructor Summary
Constructors Constructor Description PushJobDetails()
Default constructor.PushJobDetails(java.lang.CharSequence clusterName, java.lang.Long reportTimestamp, java.util.List<PushJobDetailsStatusTuple> overallStatus, java.util.Map<java.lang.CharSequence,java.util.List<PushJobDetailsStatusTuple>> coloStatus, java.lang.CharSequence pushId, java.lang.Integer partitionCount, java.lang.Integer valueCompressionStrategy, java.lang.Boolean chunkingEnabled, java.lang.Long jobDurationInMs, java.lang.Long totalNumberOfRecords, java.lang.Long totalKeyBytes, java.lang.Long totalRawValueBytes, java.lang.Long totalCompressedValueBytes, java.lang.Long totalGzipCompressedValueBytes, java.lang.Long totalZstdWithDictCompressedValueBytes, java.util.Map<java.lang.CharSequence,java.lang.CharSequence> pushJobConfigs, java.util.Map<java.lang.CharSequence,java.lang.CharSequence> producerConfigs, java.lang.Integer pushJobLatestCheckpoint, java.lang.CharSequence failureDetails, java.lang.CharSequence sendLivenessHeartbeatFailureDetails)
All-args constructor.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Object
get(int field$)
boolean
getChunkingEnabled()
Gets the value of the 'chunkingEnabled' field.static org.apache.avro.Schema
getClassSchema()
java.lang.CharSequence
getClusterName()
Gets the value of the 'clusterName' field.java.util.Map<java.lang.CharSequence,java.util.List<PushJobDetailsStatusTuple>>
getColoStatus()
Gets the value of the 'coloStatus' field.java.lang.CharSequence
getFailureDetails()
Gets the value of the 'failureDetails' field.long
getJobDurationInMs()
Gets the value of the 'jobDurationInMs' field.java.util.List<PushJobDetailsStatusTuple>
getOverallStatus()
Gets the value of the 'overallStatus' field.int
getPartitionCount()
Gets the value of the 'partitionCount' field.java.util.Map<java.lang.CharSequence,java.lang.CharSequence>
getProducerConfigs()
Gets the value of the 'producerConfigs' field.java.lang.CharSequence
getPushId()
Gets the value of the 'pushId' field.java.util.Map<java.lang.CharSequence,java.lang.CharSequence>
getPushJobConfigs()
Gets the value of the 'pushJobConfigs' field.java.lang.Integer
getPushJobLatestCheckpoint()
Gets the value of the 'pushJobLatestCheckpoint' field.long
getReportTimestamp()
Gets the value of the 'reportTimestamp' field.org.apache.avro.Schema
getSchema()
java.lang.CharSequence
getSendLivenessHeartbeatFailureDetails()
Gets the value of the 'sendLivenessHeartbeatFailureDetails' field.org.apache.avro.specific.SpecificData
getSpecificData()
long
getTotalCompressedValueBytes()
Gets the value of the 'totalCompressedValueBytes' field.long
getTotalGzipCompressedValueBytes()
Gets the value of the 'totalGzipCompressedValueBytes' field.long
getTotalKeyBytes()
Gets the value of the 'totalKeyBytes' field.long
getTotalNumberOfRecords()
Gets the value of the 'totalNumberOfRecords' field.long
getTotalRawValueBytes()
Gets the value of the 'totalRawValueBytes' field.long
getTotalZstdWithDictCompressedValueBytes()
Gets the value of the 'totalZstdWithDictCompressedValueBytes' field.int
getValueCompressionStrategy()
Gets the value of the 'valueCompressionStrategy' field.void
put(int field$, java.lang.Object value$)
void
readExternal(java.io.ObjectInput in)
void
setChunkingEnabled(boolean value)
Sets the value of the 'chunkingEnabled' field.void
setClusterName(java.lang.CharSequence value)
Sets the value of the 'clusterName' field.void
setColoStatus(java.util.Map<java.lang.CharSequence,java.util.List<PushJobDetailsStatusTuple>> value)
Sets the value of the 'coloStatus' field.void
setFailureDetails(java.lang.CharSequence value)
Sets the value of the 'failureDetails' field.void
setJobDurationInMs(long value)
Sets the value of the 'jobDurationInMs' field.void
setOverallStatus(java.util.List<PushJobDetailsStatusTuple> value)
Sets the value of the 'overallStatus' field.void
setPartitionCount(int value)
Sets the value of the 'partitionCount' field.void
setProducerConfigs(java.util.Map<java.lang.CharSequence,java.lang.CharSequence> value)
Sets the value of the 'producerConfigs' field.void
setPushId(java.lang.CharSequence value)
Sets the value of the 'pushId' field.void
setPushJobConfigs(java.util.Map<java.lang.CharSequence,java.lang.CharSequence> value)
Sets the value of the 'pushJobConfigs' field.void
setPushJobLatestCheckpoint(java.lang.Integer value)
Sets the value of the 'pushJobLatestCheckpoint' field.void
setReportTimestamp(long value)
Sets the value of the 'reportTimestamp' field.void
setSendLivenessHeartbeatFailureDetails(java.lang.CharSequence value)
Sets the value of the 'sendLivenessHeartbeatFailureDetails' field.void
setTotalCompressedValueBytes(long value)
Sets the value of the 'totalCompressedValueBytes' field.void
setTotalGzipCompressedValueBytes(long value)
Sets the value of the 'totalGzipCompressedValueBytes' field.void
setTotalKeyBytes(long value)
Sets the value of the 'totalKeyBytes' field.void
setTotalNumberOfRecords(long value)
Sets the value of the 'totalNumberOfRecords' field.void
setTotalRawValueBytes(long value)
Sets the value of the 'totalRawValueBytes' field.void
setTotalZstdWithDictCompressedValueBytes(long value)
Sets the value of the 'totalZstdWithDictCompressedValueBytes' field.void
setValueCompressionStrategy(int value)
Sets the value of the 'valueCompressionStrategy' 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$
-
clusterName
public java.lang.CharSequence clusterName
-
reportTimestamp
public long reportTimestamp
timestamp for when the reported details were collected
-
overallStatus
public java.util.List<PushJobDetailsStatusTuple> overallStatus
-
coloStatus
public java.util.Map<java.lang.CharSequence,java.util.List<PushJobDetailsStatusTuple>> coloStatus
-
pushId
public java.lang.CharSequence pushId
-
partitionCount
public int partitionCount
-
valueCompressionStrategy
public int valueCompressionStrategy
0 => NO_OP, 1 => GZIP
-
chunkingEnabled
public boolean chunkingEnabled
-
jobDurationInMs
public long jobDurationInMs
-
totalNumberOfRecords
public long totalNumberOfRecords
total number of key value pairs pushed
-
totalKeyBytes
public long totalKeyBytes
total amount of key bytes pushed
-
totalRawValueBytes
public long totalRawValueBytes
total amount of uncompressed value bytes
-
totalCompressedValueBytes
public long totalCompressedValueBytes
total amount of compressed value bytes stored
-
totalGzipCompressedValueBytes
public long totalGzipCompressedValueBytes
total amount of Gzip compressed value bytes
-
totalZstdWithDictCompressedValueBytes
public long totalZstdWithDictCompressedValueBytes
total amount of Zstd with Dictionary compressed value bytes
-
pushJobConfigs
public java.util.Map<java.lang.CharSequence,java.lang.CharSequence> pushJobConfigs
-
producerConfigs
public java.util.Map<java.lang.CharSequence,java.lang.CharSequence> producerConfigs
-
pushJobLatestCheckpoint
public java.lang.Integer pushJobLatestCheckpoint
Latest checkpoint reached by the push job if available, negative values are known error checkpoints. Refer tocom.linkedin.venice.hadoop.VenicePushJob.PushJobCheckpoints
-
failureDetails
public java.lang.CharSequence failureDetails
-
sendLivenessHeartbeatFailureDetails
public java.lang.CharSequence sendLivenessHeartbeatFailureDetails
Failure details of sending liveness heartbeat from the push job. If no failure or the job is not enabled to send liveness heartbeat, this field is null
-
-
Constructor Detail
-
PushJobDetails
public PushJobDetails()
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should usenewBuilder()
.
-
PushJobDetails
public PushJobDetails(java.lang.CharSequence clusterName, java.lang.Long reportTimestamp, java.util.List<PushJobDetailsStatusTuple> overallStatus, java.util.Map<java.lang.CharSequence,java.util.List<PushJobDetailsStatusTuple>> coloStatus, java.lang.CharSequence pushId, java.lang.Integer partitionCount, java.lang.Integer valueCompressionStrategy, java.lang.Boolean chunkingEnabled, java.lang.Long jobDurationInMs, java.lang.Long totalNumberOfRecords, java.lang.Long totalKeyBytes, java.lang.Long totalRawValueBytes, java.lang.Long totalCompressedValueBytes, java.lang.Long totalGzipCompressedValueBytes, java.lang.Long totalZstdWithDictCompressedValueBytes, java.util.Map<java.lang.CharSequence,java.lang.CharSequence> pushJobConfigs, java.util.Map<java.lang.CharSequence,java.lang.CharSequence> producerConfigs, java.lang.Integer pushJobLatestCheckpoint, java.lang.CharSequence failureDetails, java.lang.CharSequence sendLivenessHeartbeatFailureDetails)
All-args constructor.- Parameters:
clusterName
- The new value for clusterNamereportTimestamp
- timestamp for when the reported details were collectedoverallStatus
- The new value for overallStatuscoloStatus
- The new value for coloStatuspushId
- The new value for pushIdpartitionCount
- The new value for partitionCountvalueCompressionStrategy
- 0 => NO_OP, 1 => GZIPchunkingEnabled
- The new value for chunkingEnabledjobDurationInMs
- The new value for jobDurationInMstotalNumberOfRecords
- total number of key value pairs pushedtotalKeyBytes
- total amount of key bytes pushedtotalRawValueBytes
- total amount of uncompressed value bytestotalCompressedValueBytes
- total amount of compressed value bytes storedtotalGzipCompressedValueBytes
- total amount of Gzip compressed value bytestotalZstdWithDictCompressedValueBytes
- total amount of Zstd with Dictionary compressed value bytespushJobConfigs
- The new value for pushJobConfigsproducerConfigs
- The new value for producerConfigspushJobLatestCheckpoint
- Latest checkpoint reached by the push job if available, negative values are known error checkpoints. Refer tocom.linkedin.venice.hadoop.VenicePushJob.PushJobCheckpoints
failureDetails
- The new value for failureDetailssendLivenessHeartbeatFailureDetails
- Failure details of sending liveness heartbeat from the push job. If no failure or the job is not enabled to send liveness heartbeat, this field is null
-
-
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
-
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.
-
getReportTimestamp
public long getReportTimestamp()
Gets the value of the 'reportTimestamp' field.- Returns:
- timestamp for when the reported details were collected
-
setReportTimestamp
public void setReportTimestamp(long value)
Sets the value of the 'reportTimestamp' field. timestamp for when the reported details were collected- Parameters:
value
- the value to set.
-
getOverallStatus
public java.util.List<PushJobDetailsStatusTuple> getOverallStatus()
Gets the value of the 'overallStatus' field.- Returns:
- The value of the 'overallStatus' field.
-
setOverallStatus
public void setOverallStatus(java.util.List<PushJobDetailsStatusTuple> value)
Sets the value of the 'overallStatus' field.- Parameters:
value
- the value to set.
-
getColoStatus
public java.util.Map<java.lang.CharSequence,java.util.List<PushJobDetailsStatusTuple>> getColoStatus()
Gets the value of the 'coloStatus' field.- Returns:
- The value of the 'coloStatus' field.
-
setColoStatus
public void setColoStatus(java.util.Map<java.lang.CharSequence,java.util.List<PushJobDetailsStatusTuple>> value)
Sets the value of the 'coloStatus' field.- Parameters:
value
- the value to set.
-
getPushId
public java.lang.CharSequence getPushId()
Gets the value of the 'pushId' field.- Returns:
- The value of the 'pushId' field.
-
setPushId
public void setPushId(java.lang.CharSequence value)
Sets the value of the 'pushId' field.- Parameters:
value
- the value to set.
-
getPartitionCount
public int getPartitionCount()
Gets the value of the 'partitionCount' field.- Returns:
- The value of the 'partitionCount' field.
-
setPartitionCount
public void setPartitionCount(int value)
Sets the value of the 'partitionCount' field.- Parameters:
value
- the value to set.
-
getValueCompressionStrategy
public int getValueCompressionStrategy()
Gets the value of the 'valueCompressionStrategy' field.- Returns:
- 0 => NO_OP, 1 => GZIP
-
setValueCompressionStrategy
public void setValueCompressionStrategy(int value)
Sets the value of the 'valueCompressionStrategy' field. 0 => NO_OP, 1 => GZIP- Parameters:
value
- the value to set.
-
getChunkingEnabled
public boolean getChunkingEnabled()
Gets the value of the 'chunkingEnabled' field.- Returns:
- The value of the 'chunkingEnabled' field.
-
setChunkingEnabled
public void setChunkingEnabled(boolean value)
Sets the value of the 'chunkingEnabled' field.- Parameters:
value
- the value to set.
-
getJobDurationInMs
public long getJobDurationInMs()
Gets the value of the 'jobDurationInMs' field.- Returns:
- The value of the 'jobDurationInMs' field.
-
setJobDurationInMs
public void setJobDurationInMs(long value)
Sets the value of the 'jobDurationInMs' field.- Parameters:
value
- the value to set.
-
getTotalNumberOfRecords
public long getTotalNumberOfRecords()
Gets the value of the 'totalNumberOfRecords' field.- Returns:
- total number of key value pairs pushed
-
setTotalNumberOfRecords
public void setTotalNumberOfRecords(long value)
Sets the value of the 'totalNumberOfRecords' field. total number of key value pairs pushed- Parameters:
value
- the value to set.
-
getTotalKeyBytes
public long getTotalKeyBytes()
Gets the value of the 'totalKeyBytes' field.- Returns:
- total amount of key bytes pushed
-
setTotalKeyBytes
public void setTotalKeyBytes(long value)
Sets the value of the 'totalKeyBytes' field. total amount of key bytes pushed- Parameters:
value
- the value to set.
-
getTotalRawValueBytes
public long getTotalRawValueBytes()
Gets the value of the 'totalRawValueBytes' field.- Returns:
- total amount of uncompressed value bytes
-
setTotalRawValueBytes
public void setTotalRawValueBytes(long value)
Sets the value of the 'totalRawValueBytes' field. total amount of uncompressed value bytes- Parameters:
value
- the value to set.
-
getTotalCompressedValueBytes
public long getTotalCompressedValueBytes()
Gets the value of the 'totalCompressedValueBytes' field.- Returns:
- total amount of compressed value bytes stored
-
setTotalCompressedValueBytes
public void setTotalCompressedValueBytes(long value)
Sets the value of the 'totalCompressedValueBytes' field. total amount of compressed value bytes stored- Parameters:
value
- the value to set.
-
getTotalGzipCompressedValueBytes
public long getTotalGzipCompressedValueBytes()
Gets the value of the 'totalGzipCompressedValueBytes' field.- Returns:
- total amount of Gzip compressed value bytes
-
setTotalGzipCompressedValueBytes
public void setTotalGzipCompressedValueBytes(long value)
Sets the value of the 'totalGzipCompressedValueBytes' field. total amount of Gzip compressed value bytes- Parameters:
value
- the value to set.
-
getTotalZstdWithDictCompressedValueBytes
public long getTotalZstdWithDictCompressedValueBytes()
Gets the value of the 'totalZstdWithDictCompressedValueBytes' field.- Returns:
- total amount of Zstd with Dictionary compressed value bytes
-
setTotalZstdWithDictCompressedValueBytes
public void setTotalZstdWithDictCompressedValueBytes(long value)
Sets the value of the 'totalZstdWithDictCompressedValueBytes' field. total amount of Zstd with Dictionary compressed value bytes- Parameters:
value
- the value to set.
-
getPushJobConfigs
public java.util.Map<java.lang.CharSequence,java.lang.CharSequence> getPushJobConfigs()
Gets the value of the 'pushJobConfigs' field.- Returns:
- The value of the 'pushJobConfigs' field.
-
setPushJobConfigs
public void setPushJobConfigs(java.util.Map<java.lang.CharSequence,java.lang.CharSequence> value)
Sets the value of the 'pushJobConfigs' field.- Parameters:
value
- the value to set.
-
getProducerConfigs
public java.util.Map<java.lang.CharSequence,java.lang.CharSequence> getProducerConfigs()
Gets the value of the 'producerConfigs' field.- Returns:
- The value of the 'producerConfigs' field.
-
setProducerConfigs
public void setProducerConfigs(java.util.Map<java.lang.CharSequence,java.lang.CharSequence> value)
Sets the value of the 'producerConfigs' field.- Parameters:
value
- the value to set.
-
getPushJobLatestCheckpoint
public java.lang.Integer getPushJobLatestCheckpoint()
Gets the value of the 'pushJobLatestCheckpoint' field.- Returns:
- Latest checkpoint reached by the push job if available, negative values are known error checkpoints. Refer to
com.linkedin.venice.hadoop.VenicePushJob.PushJobCheckpoints
-
setPushJobLatestCheckpoint
public void setPushJobLatestCheckpoint(java.lang.Integer value)
Sets the value of the 'pushJobLatestCheckpoint' field. Latest checkpoint reached by the push job if available, negative values are known error checkpoints. Refer tocom.linkedin.venice.hadoop.VenicePushJob.PushJobCheckpoints
- Parameters:
value
- the value to set.
-
getFailureDetails
public java.lang.CharSequence getFailureDetails()
Gets the value of the 'failureDetails' field.- Returns:
- The value of the 'failureDetails' field.
-
setFailureDetails
public void setFailureDetails(java.lang.CharSequence value)
Sets the value of the 'failureDetails' field.- Parameters:
value
- the value to set.
-
getSendLivenessHeartbeatFailureDetails
public java.lang.CharSequence getSendLivenessHeartbeatFailureDetails()
Gets the value of the 'sendLivenessHeartbeatFailureDetails' field.- Returns:
- Failure details of sending liveness heartbeat from the push job. If no failure or the job is not enabled to send liveness heartbeat, this field is null
-
setSendLivenessHeartbeatFailureDetails
public void setSendLivenessHeartbeatFailureDetails(java.lang.CharSequence value)
Sets the value of the 'sendLivenessHeartbeatFailureDetails' field. Failure details of sending liveness heartbeat from the push job. If no failure or the job is not enabled to send liveness heartbeat, this field is null- 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
-
-