org.apache.spark.storage

DiskBlockObjectWriter

class DiskBlockObjectWriter extends BlockObjectWriter with Logging

BlockObjectWriter which writes directly to a file on disk. Appends to the given file.

Linear Supertypes
Logging, BlockObjectWriter, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. DiskBlockObjectWriter
  2. Logging
  3. BlockObjectWriter
  4. AnyRef
  5. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new DiskBlockObjectWriter(blockId: BlockId, file: File, serializer: Serializer, bufferSize: Int, compressStream: (OutputStream) ⇒ OutputStream)

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  7. def clone(): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  8. def close(): Unit

    Definition Classes
    DiskBlockObjectWriter → BlockObjectWriter

  9. def commit(): Long

    Flush the partial writes and commit them as a single atomic block.

    Flush the partial writes and commit them as a single atomic block. Return the number of bytes written for this commit.

    Definition Classes
    DiskBlockObjectWriter → BlockObjectWriter

  10. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  11. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  12. def fileSegment(): FileSegment

    Returns the file segment of committed data that this Writer has written.

    Returns the file segment of committed data that this Writer has written.

    Definition Classes
    DiskBlockObjectWriter → BlockObjectWriter

  13. def finalize(): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  14. final def getClass(): java.lang.Class[_]

    Definition Classes
    AnyRef → Any

  15. def hashCode(): Int

    Definition Classes
    AnyRef → Any

  16. def initLogging(): Unit

    Attributes
    protected
    Definition Classes
    Logging

  17. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  18. def isOpen: Boolean

    Definition Classes
    DiskBlockObjectWriter → BlockObjectWriter

  19. def isTraceEnabled(): Boolean

    Attributes
    protected
    Definition Classes
    Logging

  20. def log: Logger

    Attributes
    protected
    Definition Classes
    Logging

  21. def logDebug(msg: ⇒ String, throwable: Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging

  22. def logDebug(msg: ⇒ String): Unit

    Attributes
    protected
    Definition Classes
    Logging

  23. def logError(msg: ⇒ String, throwable: Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging

  24. def logError(msg: ⇒ String): Unit

    Attributes
    protected
    Definition Classes
    Logging

  25. def logInfo(msg: ⇒ String, throwable: Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging

  26. def logInfo(msg: ⇒ String): Unit

    Attributes
    protected
    Definition Classes
    Logging

  27. def logTrace(msg: ⇒ String, throwable: Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging

  28. def logTrace(msg: ⇒ String): Unit

    Attributes
    protected
    Definition Classes
    Logging

  29. def logWarning(msg: ⇒ String, throwable: Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging

  30. def logWarning(msg: ⇒ String): Unit

    Attributes
    protected
    Definition Classes
    Logging

  31. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  32. final def notify(): Unit

    Definition Classes
    AnyRef

  33. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  34. def open(): BlockObjectWriter

    Definition Classes
    DiskBlockObjectWriter → BlockObjectWriter

  35. def revertPartialWrites(): Unit

    Reverts writes that haven't been flushed yet.

    Reverts writes that haven't been flushed yet. Callers should invoke this function when there are runtime exceptions.

    Definition Classes
    DiskBlockObjectWriter → BlockObjectWriter

  36. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef

  37. def timeWriting(): Long

    Cumulative time spent performing blocking writes, in ns.

    Cumulative time spent performing blocking writes, in ns.

    Definition Classes
    DiskBlockObjectWriter → BlockObjectWriter

  38. def toString(): String

    Definition Classes
    AnyRef → Any

  39. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

  40. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

  41. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

  42. def write(value: Any): Unit

    Writes an object.

    Writes an object.

    Definition Classes
    DiskBlockObjectWriter → BlockObjectWriter

Inherited from Logging

Inherited from BlockObjectWriter

Inherited from AnyRef

Inherited from Any