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

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

append

LogOffset append(String stream,
                 Record record)

Appends a record to a processor's source stream.