abstract class RecordBatchBuilder[+B <: RecordBatch] extends AnyRef
A record batch builder, the base implementation takes care of keeping track of contained record ranges. Concrete implementations should additionally implement actual batch construction.
- B
Type of the batches being built.
- Alphabetic
- By Inheritance
- RecordBatchBuilder
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new RecordBatchBuilder()
Abstract Value Members
- abstract def addToBatch(record: StreamRecord): Int
Adds a record to the underlying batch and returns the number of records actually added.
Adds a record to the underlying batch and returns the number of records actually added.
- Attributes
- protected
- abstract def build(): Option[B]
Finalizes and outputs the batch.
Finalizes and outputs the batch. Returns
Noneif no records were added to the batch. - abstract def discard(): Unit
Discards the current batch, performs any necessary cleanup.
- abstract def isBatchReady: Boolean
Checks whether the current batch is ready.
Checks whether the current batch is ready. Concrete implementations can check whether the batch contains a certain amount of records or some time has passed since batch creation, etc.
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def add(record: StreamRecord): Int
Adds a new record to the current batch.
Adds a new record to the current batch. Keeps track of record ranges in the batch and delegates the actual adding to addToBatch.
- record
Record to add to batch.
- returns
Actual number of records added to the batch.
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def currentRecordRanges: Seq[StreamRange]
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()