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 |
Modifier and Type | Field and Description |
---|---|
protected ComputationPolicy |
Settings.defaultPolicy |
static ComputationPolicy |
ComputationPolicy.NONE |
Modifier and Type | Field and Description |
---|---|
protected Map<String,ComputationPolicy> |
Settings.policies |
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.
|
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.
|
Constructor and Description |
---|
Settings(int defaultConcurrency,
int defaultPartitions,
Codec<Record> defaultCodec,
ComputationPolicy defaultPolicy) |
Settings(int defaultConcurrency,
int defaultPartitions,
ComputationPolicy defaultPolicy) |
Modifier and Type | Field and Description |
---|---|
protected ComputationPolicy |
ComputationContextImpl.policy |
Modifier and Type | Method and Description |
---|---|
ComputationPolicy |
ComputationContextImpl.getPolicy() |
Constructor and Description |
---|
ComputationContextImpl(LogManager logManager,
ComputationMetadataMapping metadata,
ComputationPolicy policy) |
Modifier and Type | Field and Description |
---|---|
protected ComputationPolicy |
ComputationRunner.policy |
protected ComputationPolicy |
ComputationPool.policy |
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) |
Modifier and Type | Field and Description |
---|---|
protected ComputationPolicy |
StreamProcessorDescriptor.defaultPolicy |
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) |
Copyright © 2019 Nuxeo. All rights reserved.