Uses of Class
org.nuxeo.lib.stream.computation.log.LogStreamManager
-
Packages that use LogStreamManager Package Description org.nuxeo.lib.stream.computation.log Computation pattern implemented with Log -
-
Uses of LogStreamManager in org.nuxeo.lib.stream.computation.log
Fields in org.nuxeo.lib.stream.computation.log declared as LogStreamManager Modifier and Type Field Description protected LogStreamManager
ComputationPool. streamManager
protected LogStreamManager
ComputationRunner. streamManager
protected LogStreamManager
LogStreamProcessor. streamManager
Constructors in org.nuxeo.lib.stream.computation.log with parameters of type LogStreamManager 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)
LogStreamProcessor(LogStreamManager streamManager)
-