| 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.