Package org.nuxeo.lib.stream.computation
Interface StreamManager
-
- All Superinterfaces:
AutoCloseable
- All Known Implementing Classes:
LogStreamManager
public interface StreamManager extends AutoCloseable
Gives access to StreamProcessor and appender for source provider.- Since:
- 11.1
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description LogOffset
append(String stream, Record record)
Appends a record to a processor's source stream.void
close()
StreamProcessor
createStreamProcessor(String processorName)
Creates a registered processor without starting it.StreamProcessor
getProcessor(String processorName)
Gets a processor.Set<String>
getProcessorNames()
Gets a set of processor names.void
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
register(List<String> streams, Settings settings)
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 Detail
-
register
void 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.
-
createStreamProcessor
StreamProcessor createStreamProcessor(String processorName)
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
void register(List<String> streams, Settings settings)
Registers some source Streams without any processors.- Since:
- 11.4
-
append
LogOffset append(String stream, Record record)
Appends a record to a processor's source stream.
-
getProcessor
StreamProcessor getProcessor(String processorName)
Gets a processor.- Returns:
- null if the processor doesn't exist
- Since:
- 2021.25
-
close
void close()
- Specified by:
close
in interfaceAutoCloseable
-
-