Uses of Class
org.nuxeo.lib.stream.computation.ComputationMetadataMapping
Package
Description
The Computation pattern with a Log implementation.
Computation pattern implemented with Log
-
Uses of ComputationMetadataMapping in org.nuxeo.lib.stream.computation
Modifier and TypeFieldDescriptionprotected final List<ComputationMetadataMapping>
Topology.metadataList
protected final Map<String,
ComputationMetadataMapping> Topology.metadataMap
Modifier and TypeMethodDescriptionprotected void
Topology.generateDag
(Set<ComputationMetadataMapping> metadataSet) protected void
Topology.generateMetadataMapping
(Set<ComputationMetadataMapping> metadataSet) -
Uses of ComputationMetadataMapping in org.nuxeo.lib.stream.computation.internals
Modifier and TypeFieldDescriptionprotected final ComputationMetadataMapping
ComputationContextImpl.metadata
ModifierConstructorDescriptionComputationContextImpl
(ComputationMetadataMapping computationMetadataMapping) ComputationContextImpl
(StreamManager streamManager, ComputationMetadataMapping metadata, ComputationPolicy policy) ComputationContextImpl
(StreamManager streamManager, ComputationMetadataMapping metadata, ComputationPolicy policy, boolean isSpare) -
Uses of ComputationMetadataMapping in org.nuxeo.lib.stream.computation.log
Modifier and TypeFieldDescriptionprotected final ComputationMetadataMapping
ComputationPool.metadata
protected final ComputationMetadataMapping
ComputationRunner.metadata
Modifier and TypeMethodDescriptionprotected List<List<LogPartition>>
LogStreamProcessor.getDefaultAssignments
(ComputationMetadataMapping meta) 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)