Package org.nuxeo.lib.stream.computation
Interface StreamManager
-
- All Known Implementing Classes:
LogStreamManager
public interface StreamManager
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.StreamProcessor
createStreamProcessor(String processorName)
Creates a registered processor without starting it.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
-
-