Uses of Class
org.nuxeo.lib.stream.computation.ComputationPolicyBuilder

Packages that use ComputationPolicyBuilder

Package	Description
org.nuxeo.lib.stream.computation	The Computation pattern with a Log implementation.
org.nuxeo.runtime.stream

Uses of ComputationPolicyBuilder in org.nuxeo.lib.stream.computation

Methods in org.nuxeo.lib.stream.computation that return ComputationPolicyBuilder

Modifier and Type	Method	Description
ComputationPolicyBuilder	ComputationPolicyBuilder.batchPolicy(int capacity, Duration timeThreshold)	Defines how to group records by batch using a capacity and a time threshold.
ComputationPolicyBuilder	ComputationPolicyBuilder.continueOnFailure(boolean value)	The fallback when processing a batch has failed after applying the retry policy has failed.
ComputationPolicyBuilder	ComputationPolicyBuilder.retryPolicy(net.jodah.failsafe.RetryPolicy policy)	Defines what to do in case of failure during the batch processing.
ComputationPolicyBuilder	ComputationPolicyBuilder.skipFirstFailures(int failures)	A recovery fallback that continues processing after failure only for a limited number of time.

Constructors in org.nuxeo.lib.stream.computation with parameters of type ComputationPolicyBuilder

Constructor	Description
ComputationPolicy(ComputationPolicyBuilder builder)

Uses of ComputationPolicyBuilder in org.nuxeo.runtime.stream

Methods in org.nuxeo.runtime.stream that return ComputationPolicyBuilder

Modifier and Type	Method	Description
ComputationPolicyBuilder	StreamProcessorDescriptor.PolicyDescriptor.createPolicyBuilder()