Uses of Class
org.nuxeo.lib.stream.computation.Settings
Package
Description
The Computation pattern with a Log implementation.
Computation pattern implemented with Log
-
Uses of Settings in org.nuxeo.ecm.core.work
-
Uses of Settings in org.nuxeo.lib.stream.computation
Modifier and TypeMethodDescriptionSettings.addFilter
(String streamName, RecordFilter filter) Add a filterSettings.addFilter
(Name streamName, RecordFilter filter) Add a filterSets the codec for a stream.Sets the codec for a stream.Settings.setConcurrency
(String computationName, int concurrency) Sets the computation thread pool size.Settings.setConcurrency
(Name computationName, int concurrency) Settings.setExternal
(Name streamName, boolean external) Settings.setPartitions
(String streamName, int partitions) Settings.setPartitions
(Name streamName, int partitions) Sets the number of partitions for a stream.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.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.Modifier and TypeMethodDescriptionInitialize streams, but don't run the computationsvoid
Registers a processor and initializes the underlying streams, this is needed before creating a processor or appending record in source streams.void
Registers some source Streams without any processors.default StreamProcessor
StreamManager.registerAndCreateProcessor
(String processorName, Topology topology, Settings settings) Registers and creates a processor without starting it.Topology.toPlantuml
(Settings settings) -
Uses of Settings in org.nuxeo.lib.stream.computation.log
Modifier and TypeMethodDescriptionprotected void
LogStreamManager.initAppenders
(Collection<String> streams, Settings settings) protected void
LogStreamManager.initStream
(String streamName, Settings settings) protected void
LogStreamManager.initStreams
(Topology topology, Settings settings) void
void
protected void
LogStreamManager.registerFilters
(Collection<String> streams, Settings settings) -
Uses of Settings in org.nuxeo.runtime.stream
Modifier and TypeMethodDescriptionprotected Settings
StreamServiceImpl.getSettings
(StreamProcessorDescriptor descriptor)