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 Details

    • 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 Details

    • Builder

      public Builder(String name, int nbOutputStream)
      Parameters:
      name - the computation name
      nbOutputStream - the number of registered bulk action streams

  • Method Details

    • 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()