Uses of Interface
org.nuxeo.lib.stream.computation.StreamProcessor

Packages that use StreamProcessor

Package	Description
org.nuxeo.ecm.core.bulk
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.lib.stream.tools.command

Uses of StreamProcessor in org.nuxeo.ecm.core.bulk

Fields in org.nuxeo.ecm.core.bulk declared as StreamProcessor

Modifier and Type	Field	Description
protected StreamProcessor	BulkAdminServiceImpl.streamProcessor

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

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

Modifier and Type	Field	Description
protected StreamProcessor	StreamWorkManager.streamProcessor

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

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

Modifier and Type	Method	Description
StreamProcessor	StreamManager.createStreamProcessor(String processorName)	Creates a registered processor without starting it.
StreamProcessor	StreamManager.getProcessor(String processorName)	Gets a processor.
StreamProcessor	StreamProcessor.init(Topology topology, Settings settings)	Initialize streams, but don't run the computations
default StreamProcessor	StreamManager.registerAndCreateProcessor(String processorName, Topology topology, Settings settings)	Registers and creates a processor without starting it.

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

Classes in org.nuxeo.lib.stream.computation.log that implement StreamProcessor

Modifier and Type	Class	Description
class	LogStreamProcessor

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

Modifier and Type	Field	Description
protected final Map<String,StreamProcessor>	LogStreamManager.processors

Methods in org.nuxeo.lib.stream.computation.log that return StreamProcessor

Modifier and Type	Method	Description
StreamProcessor	LogStreamManager.createStreamProcessor(String processorName)
StreamProcessor	LogStreamManager.getProcessor(String processorName)
StreamProcessor	LogStreamProcessor.init(Topology topology, Settings settings)

Uses of StreamProcessor in org.nuxeo.lib.stream.tools.command

Fields in org.nuxeo.lib.stream.tools.command declared as StreamProcessor

Modifier and Type	Field	Description
protected StreamProcessor	MonitorCommand.processor
protected StreamProcessor	TrackerCommand.processor