Skip to content

ShuffleWriteMetricsReporter

ShuffleWriteMetricsReporter is an abstraction of shuffle write metrics reporters.

Contract

decBytesWritten

decBytesWritten(
  v: Long): Unit

decRecordsWritten

decRecordsWritten(
  v: Long): Unit

incBytesWritten

incBytesWritten(
  v: Long): Unit

incRecordsWritten

incRecordsWritten(
  v: Long): Unit

See ShuffleWriteMetrics

Used when:

incWriteTime

incWriteTime(
  v: Long): Unit

Used when:

Implementations