Package com.linkedin.venice.hadoop.task.datawriter

Interface DataWriterTaskTracker

All Superinterfaces:

TaskTracker

All Known Implementing Classes:

CounterBackedMapReduceDataWriterTaskTracker, ReporterBackedMapReduceDataWriterTaskTracker, SparkDataWriterTaskTracker

public interface DataWriterTaskTracker
extends TaskTracker

An interface to report and retrieve metrics related to data writer tasks.

Field Summary

Fields inherited from interface com.linkedin.venice.hadoop.task.TaskTracker

PROGRESS_COMPLETED, PROGRESS_NOT_SUPPORTED

Method Summary

Modifier and Type	Method	Description
default long	getDuplicateKeyWithDistinctValueCount()
default long	getOutputRecordsCount()
default long	getPartitionWriterCloseCount()
default long	getRecordTooLargeFailureCount()
default long	getRepushTtlFilterCount()
default long	getSprayAllPartitionsCount()
default long	getTotalGzipCompressedValueSize()
default long	getTotalKeySize()
default long	getTotalPutOrDeleteRecordsCount()
default long	getTotalUncompressedValueSize()
default long	getTotalValueSize()
default long	getTotalZstdCompressedValueSize()
default long	getWriteAclAuthorizationFailureCount()
default void	trackCompressedValueSize(int size)
default void	trackDuplicateKeyWithDistinctValue(int count)
default void	trackDuplicateKeyWithIdenticalValue(int count)
default void	trackEmptyRecord()
default void	trackGzipCompressedValueSize(int size)
default void	trackKeySize(int size)
default void	trackPartitionWriterClose()
default void	trackPutOrDeleteRecord()
default void	trackRecordSentToPubSub()
default void	trackRecordTooLargeFailure()
default void	trackRepushTtlFilteredRecord()
default void	trackSprayAllPartitions()
default void	trackUncompressedValueSize(int size)
default void	trackWriteAclAuthorizationFailure()
default void	trackZstdCompressedValueSize(int size)

Methods inherited from interface com.linkedin.venice.hadoop.task.TaskTracker

getProgress, heartbeat

Method Detail

trackSprayAllPartitions

default void trackSprayAllPartitions()

trackEmptyRecord

default void trackEmptyRecord()

trackKeySize

default void trackKeySize(int size)

trackUncompressedValueSize

default void trackUncompressedValueSize(int size)

trackCompressedValueSize

default void trackCompressedValueSize(int size)

trackGzipCompressedValueSize

default void trackGzipCompressedValueSize(int size)

trackZstdCompressedValueSize

default void trackZstdCompressedValueSize(int size)

trackWriteAclAuthorizationFailure

default void trackWriteAclAuthorizationFailure()

trackRecordTooLargeFailure

default void trackRecordTooLargeFailure()

trackRecordSentToPubSub

default void trackRecordSentToPubSub()

trackDuplicateKeyWithDistinctValue

default void trackDuplicateKeyWithDistinctValue(int count)

trackDuplicateKeyWithIdenticalValue

default void trackDuplicateKeyWithIdenticalValue(int count)

trackRepushTtlFilteredRecord

default void trackRepushTtlFilteredRecord()

trackPutOrDeleteRecord

default void trackPutOrDeleteRecord()

trackPartitionWriterClose

default void trackPartitionWriterClose()

getSprayAllPartitionsCount

default long getSprayAllPartitionsCount()

getTotalKeySize

default long getTotalKeySize()

getTotalValueSize

default long getTotalValueSize()

getTotalUncompressedValueSize

default long getTotalUncompressedValueSize()

getTotalGzipCompressedValueSize

default long getTotalGzipCompressedValueSize()

getTotalZstdCompressedValueSize

default long getTotalZstdCompressedValueSize()

getRecordTooLargeFailureCount

default long getRecordTooLargeFailureCount()

getWriteAclAuthorizationFailureCount

default long getWriteAclAuthorizationFailureCount()

getDuplicateKeyWithDistinctValueCount

default long getDuplicateKeyWithDistinctValueCount()

getOutputRecordsCount

default long getOutputRecordsCount()

getPartitionWriterCloseCount

default long getPartitionWriterCloseCount()

getRepushTtlFilterCount

default long getRepushTtlFilterCount()

getTotalPutOrDeleteRecordsCount

default long getTotalPutOrDeleteRecordsCount()