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

Packages that use ComputationPolicy

Package	Description
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.lib.stream.computation

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

Modifier and Type	Field and 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 and Description
protected Map<String,ComputationPolicy>	Settings.policies

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

Modifier and Type	Method and 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.

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

Modifier and Type	Method and Description
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.

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

Constructor and Description
Settings(int defaultConcurrency, int defaultPartitions, Codec<Record> defaultCodec, ComputationPolicy defaultPolicy)
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 and Description
protected ComputationPolicy	ComputationContextImpl.policy

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

Modifier and Type	Method and Description
ComputationPolicy	ComputationContextImpl.getPolicy()

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

Constructor and Description
ComputationContextImpl(LogManager logManager, ComputationMetadataMapping metadata, ComputationPolicy policy)

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 and Description
protected ComputationPolicy	ComputationRunner.policy
protected ComputationPolicy	ComputationPool.policy

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

Constructor and Description
ComputationPool(Supplier<Computation> supplier, ComputationMetadataMapping metadata, List<List<LogPartition>> defaultAssignments, LogManager manager, Codec<Record> inputCodec, Codec<Record> outputCodec, ComputationPolicy policy)
ComputationRunner(Supplier<Computation> supplier, ComputationMetadataMapping metadata, List<LogPartition> defaultAssignment, LogManager logManager, Codec<Record> inputCodec, Codec<Record> outputCodec, ComputationPolicy policy)

Uses of ComputationPolicy in org.nuxeo.runtime.stream

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

Modifier and Type	Field and Description
protected ComputationPolicy	StreamProcessorDescriptor.defaultPolicy

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

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