Package org.nuxeo.lib.stream.pattern.consumer

Class BatchPolicy.Builder

java.lang.Object

org.nuxeo.lib.stream.pattern.consumer.BatchPolicy.Builder

Enclosing class:

BatchPolicy

public static class BatchPolicy.Builder
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected int	capacity
protected Duration	threshold

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Builder()

Method Summary

Modifier and Type	Method	Description
BatchPolicy	build()
BatchPolicy.Builder	capacity(int capacity)	Set the capacity of the batch.
BatchPolicy.Builder	timeThreshold(Duration threshold)	Set the time threshold to fill a batch.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

capacity

protected int capacity

threshold

protected Duration threshold

Constructor Details

Builder

protected Builder()

Method Details

capacity

public BatchPolicy.Builder capacity(int capacity)

Set the capacity of the batch.

timeThreshold

public BatchPolicy.Builder timeThreshold(Duration threshold)

Set the time threshold to fill a batch.

build

public BatchPolicy build()