case class Builder[B <: RecordBatch](_recordBatcher: RecordBatcher[B], _batchStorage: RecordBatchStorage[B], _batchCommitQueueSize: Int, _partitionGrouping: (TopicPartition) => String, _retryPolicy: Policy) extends Sink.Builder with Product with Serializable
- Alphabetic
- By Inheritance
- Builder
- Serializable
- Product
- Equals
- Builder
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new Builder(_recordBatcher: RecordBatcher[B], _batchStorage: RecordBatchStorage[B], _batchCommitQueueSize: Int, _partitionGrouping: (TopicPartition) => String, _retryPolicy: Policy)
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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def batchCommitQueueSize(size: Int): Builder[B]
Sets the max number of pending batches queued to be committed to storage.
Sets the max number of pending batches queued to be committed to storage. Consumption stops when the queue fills up.
- def batchStorage(storage: RecordBatchStorage[B]): Builder[B]
Sets the storage, e.g.
Sets the storage, e.g. HDFS.
- def build(): RecordBatchingSink[B]
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- 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()
- def partitionGrouping(grouping: (TopicPartition) => String): Builder[B]
Sets the partition grouping, can be used to route records to different batches.
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- def recordBatcher(batcher: RecordBatcher[B]): Builder[B]
Sets the record batcher to use.
- def retryPolicy(retries: Int, initialDelay: Duration, backoffFactor: Int): Builder[B]
Sets the retry policy for all retriable operations, i.e.
Sets the retry policy for all retriable operations, i.e. recovery, batch commit and new batch creation.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- 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()