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

Packages that use ComputationPolicy

Package	Description
org.nuxeo.ecm.automation.core.operations.services.workmanager
org.nuxeo.lib.stream.computation	The Computation pattern with a Log implementation.
org.nuxeo.lib.stream.computation.internals
org.nuxeo.lib.stream.computation.log	Computation pattern implemented with Log
org.nuxeo.runtime.stream

Uses of ComputationPolicy in org.nuxeo.ecm.automation.core.operations.services.workmanager

Methods in org.nuxeo.ecm.automation.core.operations.services.workmanager that return ComputationPolicy

Modifier and Type	Method	Description
protected ComputationPolicy	WorkManagerRunWorkInFailure.getComputationPolicy()

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

Fields in org.nuxeo.lib.stream.computation declared as ComputationPolicy

Modifier and Type	Field	Description
protected ComputationPolicy	Settings.defaultPolicy
static ComputationPolicy	ComputationPolicy.NONE

Fields in org.nuxeo.lib.stream.computation with type parameters of type ComputationPolicy

Modifier and Type	Field	Description
protected Map<Name,ComputationPolicy>	Settings.policies

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

Modifier and Type	Method	Description
ComputationPolicy	ComputationPolicyBuilder.build()	Creates the policy.
ComputationPolicy	ComputationContext.getPolicy()	Gets the policy used to run the computation.
ComputationPolicy	Settings.getPolicy(String computationName)	Gets the policy for a computation.
ComputationPolicy	Settings.getPolicy(Name computationName)	Gets the policy for a computation.

Methods in org.nuxeo.lib.stream.computation with parameters of type ComputationPolicy

Modifier and Type	Method	Description
protected String	Topology.compactPolicy(ComputationPolicy policy)
Settings	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	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.

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

Constructor	Description
Settings(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

Fields in org.nuxeo.lib.stream.computation.internals declared as ComputationPolicy

Modifier and Type	Field	Description
protected ComputationPolicy	ComputationContextImpl.policy

Methods in org.nuxeo.lib.stream.computation.internals that return ComputationPolicy

Modifier and Type	Method	Description
ComputationPolicy	ComputationContextImpl.getPolicy()

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

Constructor	Description
ComputationContextImpl(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

Fields in org.nuxeo.lib.stream.computation.log declared as ComputationPolicy

Modifier and Type	Field	Description
protected ComputationPolicy	ComputationPool.policy
protected ComputationPolicy	ComputationRunner.policy

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

Constructor	Description
ComputationPool(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

Fields in org.nuxeo.runtime.stream declared as ComputationPolicy

Modifier and Type	Field	Description
protected ComputationPolicy	StreamProcessorDescriptor.defaultPolicy

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

Modifier and Type	Method	Description
protected ComputationPolicy	StreamProcessorDescriptor.getComputationPolicy(StreamProcessorDescriptor.PolicyDescriptor policyDescriptor)
ComputationPolicy	StreamProcessorDescriptor.getDefaultPolicy()
ComputationPolicy	DefaultNuxeoComputationPolicy.getPolicy(StreamProcessorDescriptor.PolicyDescriptor descriptor)
ComputationPolicy	StreamComputationPolicy.getPolicy(StreamProcessorDescriptor.PolicyDescriptor descriptor)	Returns a custom computation policy from a descriptor.
ComputationPolicy	StreamProcessorDescriptor.getPolicy(String computationName)