Class TimeTrackingOutputStream

Object
java.io.OutputStream
org.apache.spark.storage.TimeTrackingOutputStream
All Implemented Interfaces:
Closeable, Flushable, AutoCloseable

@Private public final class TimeTrackingOutputStream extends OutputStream
Intercepts write calls and tracks total time spent writing in order to update shuffle write metrics. Not thread safe.