Packages

c

org.apache.spark.storage

TimeTrackingOutputStream

final class TimeTrackingOutputStream extends OutputStream

Intercepts write calls and tracks total time spent writing in order to update shuffle write metrics. Not thread safe.

Annotations
@Private()
Source
TimeTrackingOutputStream.java
Linear Supertypes
OutputStream, Flushable, Closeable, AutoCloseable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TimeTrackingOutputStream
  2. OutputStream
  3. Flushable
  4. Closeable
  5. AutoCloseable
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new TimeTrackingOutputStream(writeMetrics: ShuffleWriteMetricsReporter, outputStream: OutputStream)

Value Members

  1. def close(): Unit
    Definition Classes
    TimeTrackingOutputStream → OutputStream → Closeable → AutoCloseable
    Annotations
    @Override()
  2. def flush(): Unit
    Definition Classes
    TimeTrackingOutputStream → OutputStream → Flushable
    Annotations
    @Override()
  3. def write(b: Array[Byte], off: Int, len: Int): Unit
    Definition Classes
    TimeTrackingOutputStream → OutputStream
    Annotations
    @Override()
  4. def write(b: Array[Byte]): Unit
    Definition Classes
    TimeTrackingOutputStream → OutputStream
    Annotations
    @Override()
  5. def write(b: Int): Unit
    Definition Classes
    TimeTrackingOutputStream → OutputStream
    Annotations
    @Override()