Class

org.apache.spark.streaming.util

WriteAheadLog

Related Doc: package util

Permalink

abstract class WriteAheadLog extends AnyRef

Source
WriteAheadLog.java
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. WriteAheadLog
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new WriteAheadLog()

    Permalink

Abstract Value Members

  1. abstract def clean(threshTime: Long, waitForCompletion: Boolean): Unit

    Permalink

  2. abstract def close(): Unit

    Permalink

  3. abstract def read(handle: WriteAheadLogRecordHandle): ByteBuffer

    Permalink

  4. abstract def readAll(): Iterator[ByteBuffer]

    Permalink

  5. abstract def write(record: ByteBuffer, time: Long): WriteAheadLogRecordHandle

    Permalink