Uses of Interface
io.debezium.pipeline.source.spi.StreamingChangeEventSource

Packages that use StreamingChangeEventSource

Package	Description
io.debezium.pipeline
io.debezium.pipeline.source.spi

Uses of StreamingChangeEventSource in io.debezium.pipeline

Fields in io.debezium.pipeline declared as StreamingChangeEventSource

Modifier and Type	Field	Description
protected StreamingChangeEventSource<P,O>	ChangeEventSourceCoordinator.streamingSource

Methods in io.debezium.pipeline that return types with arguments of type StreamingChangeEventSource

Modifier and Type	Method	Description
Optional<StreamingChangeEventSource<P,O>>	ChangeEventSourceCoordinator.getStreamingSource()	Returns the current streaming change event source, if available.

Uses of StreamingChangeEventSource in io.debezium.pipeline.source.spi

Methods in io.debezium.pipeline.source.spi that return StreamingChangeEventSource

Modifier and Type	Method	Description
StreamingChangeEventSource<P,O>	ChangeEventSourceFactory.getStreamingChangeEventSource()	Returns a streaming change event source that starts streaming at the given offset.