Package org.nuxeo.lib.stream.computation
Interface StreamManager
- All Superinterfaces:
AutoCloseable
- All Known Implementing Classes:
LogStreamManager
Gives access to StreamProcessor and appender for source provider.
- Since:
- 11.1
-
Method Summary
Modifier and TypeMethodDescriptionAppends a record to a processor's source stream.void
close()
createStreamProcessor
(String processorName) Creates a registered processor without starting it.getProcessor
(String processorName) Gets a processor.Gets a set of processor names.void
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
registerAndCreateProcessor
(String processorName, Topology topology, Settings settings) Registers and creates a processor without starting it.
-
Method Details
-
register
Registers a processor and initializes the underlying streams, this is needed before creating a processor or appending record in source streams. -
createStreamProcessor
Creates a registered processor without starting it. -
registerAndCreateProcessor
default StreamProcessor registerAndCreateProcessor(String processorName, Topology topology, Settings settings) Registers and creates a processor without starting it. -
register
Registers some source Streams without any processors.- Since:
- 11.4
-
append
Appends a record to a processor's source stream. -
getProcessorNames
Gets a set of processor names.- Since:
- 2021.25
-
getProcessor
Gets a processor.- Returns:
- null if the processor doesn't exist
- Since:
- 2021.25
-
close
void close()- Specified by:
close
in interfaceAutoCloseable
-