Packages

trait FileRecordBatch extends RecordBatch

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. FileRecordBatch
  2. RecordBatch
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract val file: File
  2. abstract def recordRanges: Seq[StreamRange]

    Gets the ranges of records in each topic partition contained in the batch.

    Gets the ranges of records in each topic partition contained in the batch.

    Definition Classes
    RecordBatch

Concrete Value Members

  1. def discard(): Boolean

    Performs any necessary cleanup after the batch is no longer needed, e.g.

    Performs any necessary cleanup after the batch is no longer needed, e.g. deletes any underlying files.

    returns

    Whether the discard operation succeeded.

    Definition Classes
    FileRecordBatchRecordBatch