Package | Description |
---|---|
org.nuxeo.lib.stream.computation |
The Computation pattern with a Log implementation.
|
Modifier and Type | Method and 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.
|
Constructor and Description |
---|
ComputationPolicy(ComputationPolicyBuilder builder) |
Copyright © 2019 Nuxeo. All rights reserved.