org.apache.hive.spark.client.metrics

Class ShuffleWriteMetrics

java.lang.Object

org.apache.hive.spark.client.metrics.ShuffleWriteMetrics

All Implemented Interfaces:

Serializable

@InterfaceAudience.Private
public class ShuffleWriteMetrics
extends Object
implements Serializable

Metrics pertaining to writing shuffle data.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
long	shuffleBytesWritten Number of bytes written for the shuffle by tasks.
long	shuffleWriteTime Time tasks spent blocking on writes to disk or buffer cache, in nanoseconds.

Constructor Summary

Constructors

Constructor and Description
ShuffleWriteMetrics(long shuffleBytesWritten, long shuffleWriteTime)
ShuffleWriteMetrics(org.apache.spark.executor.TaskMetrics metrics)

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

shuffleBytesWritten

public final long shuffleBytesWritten

Number of bytes written for the shuffle by tasks.

shuffleWriteTime

public final long shuffleWriteTime

Time tasks spent blocking on writes to disk or buffer cache, in nanoseconds.

Constructor Detail

ShuffleWriteMetrics

public ShuffleWriteMetrics(long shuffleBytesWritten,
                           long shuffleWriteTime)

ShuffleWriteMetrics

public ShuffleWriteMetrics(org.apache.spark.executor.TaskMetrics metrics)