Uses of Class
org.nuxeo.lib.stream.computation.ComputationPolicy
Package
Description
The Computation pattern with a Log implementation.
Computation pattern implemented with Log
-
Uses of ComputationPolicy in org.nuxeo.ecm.automation.core.operations.services.workmanager
Modifier and TypeMethodDescriptionprotected ComputationPolicy
WorkManagerRunWorkInFailure.getComputationPolicy()
-
Uses of ComputationPolicy in org.nuxeo.lib.stream.computation
Modifier and TypeFieldDescriptionprotected final ComputationPolicy
Settings.defaultPolicy
static final ComputationPolicy
ComputationPolicy.NONE
Modifier and TypeMethodDescriptionComputationPolicyBuilder.build()
Creates the policy.ComputationContext.getPolicy()
Gets the policy used to run the computation.Gets the policy for a computation.Gets the policy for a computation.Modifier and TypeMethodDescriptionprotected String
Topology.compactPolicy
(ComputationPolicy policy) Settings.setPolicy
(String computationName, ComputationPolicy policy) Sets the policy for a computation, when using default as computationName this sets the default policy for all computations in the processor.Settings.setPolicy
(Name computationName, ComputationPolicy policy) Sets the policy for a computation, when using default as computationName this sets the default policy for all computations in the processor.ModifierConstructorDescriptionSettings
(int defaultConcurrency, int defaultPartitions, Codec<Record> defaultCodec, ComputationPolicy defaultPolicy) Settings
(int defaultConcurrency, int defaultPartitions, Codec<Record> defaultCodec, ComputationPolicy defaultPolicy, RecordFilterChain defaultFilter) Settings
(int defaultConcurrency, int defaultPartitions, Codec<Record> defaultCodec, ComputationPolicy defaultPolicy, RecordFilterChain defaultFilter, boolean defaultExternal) Settings
(int defaultConcurrency, int defaultPartitions, ComputationPolicy defaultPolicy) -
Uses of ComputationPolicy in org.nuxeo.lib.stream.computation.internals
ModifierConstructorDescriptionComputationContextImpl
(StreamManager streamManager, ComputationMetadataMapping metadata, ComputationPolicy policy) ComputationContextImpl
(StreamManager streamManager, ComputationMetadataMapping metadata, ComputationPolicy policy, boolean isSpare) -
Uses of ComputationPolicy in org.nuxeo.lib.stream.computation.log
Modifier and TypeFieldDescriptionprotected final ComputationPolicy
ComputationPool.policy
protected final ComputationPolicy
ComputationRunner.policy
ModifierConstructorDescriptionComputationPool
(Supplier<Computation> supplier, ComputationMetadataMapping metadata, List<List<LogPartition>> defaultAssignments, LogStreamManager streamManager, ComputationPolicy policy) ComputationRunner
(Supplier<Computation> supplier, ComputationMetadataMapping metadata, List<LogPartition> defaultAssignment, LogStreamManager streamManager, ComputationPolicy policy) -
Uses of ComputationPolicy in org.nuxeo.runtime.stream
Modifier and TypeFieldDescriptionprotected ComputationPolicy
StreamProcessorDescriptor.defaultPolicy
Modifier and TypeMethodDescriptionprotected ComputationPolicy
StreamProcessorDescriptor.getComputationPolicy
(StreamProcessorDescriptor.PolicyDescriptor policyDescriptor) StreamProcessorDescriptor.getDefaultPolicy()
DefaultNuxeoComputationPolicy.getPolicy
(StreamProcessorDescriptor.PolicyDescriptor descriptor) StreamComputationPolicy.getPolicy
(StreamProcessorDescriptor.PolicyDescriptor descriptor) Returns a custom computation policy from a descriptor.