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 Logorg.nuxeo.lib.stream.tools.command org.nuxeo.runtime.stream -
-
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
StreamProcessor. init(Topology topology, Settings settings)
Initialize streams, but don't run the computationsdefault 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
Methods in org.nuxeo.lib.stream.computation.log that return StreamProcessor Modifier and Type Method Description StreamProcessor
LogStreamManager. createStreamProcessor(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
-
Uses of StreamProcessor in org.nuxeo.runtime.stream
Fields in org.nuxeo.runtime.stream with type parameters of type StreamProcessor Modifier and Type Field Description protected Map<String,StreamProcessor>
StreamServiceImpl. processors
-