Package org.nuxeo.ecm.core.bulk.computation

Class BulkScrollerComputation.Builder

java.lang.Object

org.nuxeo.ecm.core.bulk.computation.BulkScrollerComputation.Builder

Enclosing class:

BulkScrollerComputation

public static class BulkScrollerComputation.Builder
extends Object

Since:

11.4

Field Summary

Fields

Modifier and Type	Field	Description
protected String	name
protected int	nbOutputStreams
protected boolean	produceImmediate
protected int	produceImmediateThreshold
protected long	queryLimit
protected int	scrollBatchSize
protected int	scrollKeepAliveSeconds
protected Duration	transactionTimeout

Constructor Summary

Constructors

Constructor	Description
Builder(String name, int nbOutputStream)

Method Summary

Modifier and Type	Method	Description
BulkScrollerComputation	build()
BulkScrollerComputation.Builder	setProduceImmediate(boolean produceImmediate)
BulkScrollerComputation.Builder	setProduceImmediateThreshold(int produceImmediateThreshold)
BulkScrollerComputation.Builder	setScrollBatchSize(int scrollBatchSize)
BulkScrollerComputation.Builder	setScrollKeepAliveSeconds(int scrollKeepAliveSeconds)
BulkScrollerComputation.Builder	setTransactionTimeout(Duration transactionTimeout)

Methods inherited from class java.lang.Object

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

Field Detail

name

protected String name

nbOutputStreams

protected int nbOutputStreams

scrollBatchSize

protected int scrollBatchSize

scrollKeepAliveSeconds

protected int scrollKeepAliveSeconds

produceImmediate

protected boolean produceImmediate

produceImmediateThreshold

protected int produceImmediateThreshold

transactionTimeout

protected Duration transactionTimeout

queryLimit

protected long queryLimit

Constructor Detail

Builder

public Builder(String name,
               int nbOutputStream)

Parameters:

name - the computation name

nbOutputStream - the number of registered bulk action streams

Method Detail

setScrollBatchSize

public BulkScrollerComputation.Builder setScrollBatchSize(int scrollBatchSize)

Parameters:

scrollBatchSize - the batch size to scroll

setScrollKeepAliveSeconds

public BulkScrollerComputation.Builder setScrollKeepAliveSeconds(int scrollKeepAliveSeconds)

Parameters:

scrollKeepAliveSeconds - the scroll lifetime between fetch

setProduceImmediate

public BulkScrollerComputation.Builder setProduceImmediate(boolean produceImmediate)

Parameters:

produceImmediate - whether or not the record should be produced immediately while scrolling

setProduceImmediateThreshold

public BulkScrollerComputation.Builder setProduceImmediateThreshold(int produceImmediateThreshold)

Parameters:

produceImmediateThreshold - produce record immediately after the threshold to prevent OOM

setTransactionTimeout

public BulkScrollerComputation.Builder setTransactionTimeout(Duration transactionTimeout)

Parameters:

transactionTimeout - set an explicit transaction timeout for the scroll

build

public BulkScrollerComputation build()