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

Packages that use Settings

Package	Description
org.nuxeo.ecm.core.work
org.nuxeo.lib.stream.computation	The Computation pattern with a Log implementation.
org.nuxeo.lib.stream.computation.log	Computation pattern implemented with Log
org.nuxeo.runtime.stream

Uses of Settings in org.nuxeo.ecm.core.work

Fields in org.nuxeo.ecm.core.work declared as Settings

Modifier and Type	Field	Description
protected Settings	StreamWorkManager.settings

Uses of Settings in org.nuxeo.lib.stream.computation

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

Modifier and Type	Method	Description
Settings	Settings.addFilter(String streamName, RecordFilter filter)	Add a filter
Settings	Settings.addFilter(Name streamName, RecordFilter filter)	Add a filter
Settings	Settings.setCodec(String streamName, Codec<Record> codec)	Sets the codec for a stream.
Settings	Settings.setCodec(Name streamName, Codec<Record> codec)	Sets the codec for a stream.
Settings	Settings.setConcurrency(String computationName, int concurrency)	Sets the computation thread pool size.
Settings	Settings.setConcurrency(Name computationName, int concurrency)
Settings	Settings.setExternal(Name streamName, boolean external)
Settings	Settings.setPartitions(String streamName, int partitions)
Settings	Settings.setPartitions(Name streamName, int partitions)	Sets the number of partitions for a stream.
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.
Settings	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.

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

Modifier and Type	Method	Description
StreamProcessor	StreamProcessor.init(Topology topology, Settings settings)	Initialize streams, but don't run the computations
void	StreamManager.register(String processorName, Topology topology, Settings settings)	Registers a processor and initializes the underlying streams, this is needed before creating a processor or appending record in source streams.
void	StreamManager.register(List<String> streams, Settings settings)	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.
String	Topology.toPlantuml(Settings settings)

Uses of Settings in org.nuxeo.lib.stream.computation.log

Fields in org.nuxeo.lib.stream.computation.log declared as Settings

Modifier and Type	Field	Description
protected Settings	LogStreamProcessor.settings

Fields in org.nuxeo.lib.stream.computation.log with type parameters of type Settings

Modifier and Type	Field	Description
protected Map<String,Settings>	LogStreamManager.settings

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

Modifier and Type	Method	Description
StreamProcessor	LogStreamProcessor.init(Topology topology, Settings settings)
protected 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	LogStreamManager.register(String processorName, Topology topology, Settings settings)
void	LogStreamManager.register(List<String> streams, Settings settings)
protected void	LogStreamManager.registerFilters(Collection<String> streams, Settings settings)

Uses of Settings in org.nuxeo.runtime.stream

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

Modifier and Type	Method	Description
protected Settings	StreamServiceImpl.getSettings(StreamProcessorDescriptor descriptor)