-
WriteOptions.Builder.backpressureStrategy(io.reactivex.rxjava3.core.BackpressureOverflowStrategy backpressureStrategy)
Set the strategy to deal with buffer overflow when using onBackpressureBuffer.
WriteOptions.Builder.batchSize(int batchSize)
Set the number of data point to collect in batch.
The client maintains a buffer for failed writes so that the writes will be retried later on.
Creates a builder instance.
The base for the exponential retry delay.
Set the time to wait at most (milliseconds).
Jitters the batch flush interval by a random amount.
The number of max retries when write fails.
The maximum delay between each retry attempt in milliseconds.
The maximum total retry timeout in milliseconds.
Set the the time to wait before retry unsuccessful write (milliseconds).
WriteOptions.Builder.writeScheduler(io.reactivex.rxjava3.core.Scheduler writeScheduler)
Set the scheduler which is used for write data points.