Uses of Interface
org.apache.flink.api.connector.source.SourceEvent

Packages that use SourceEvent

Package	Description
org.apache.flink.api.connector.source

Uses of SourceEvent in org.apache.flink.api.connector.source

Methods in org.apache.flink.api.connector.source with parameters of type SourceEvent

Modifier and Type	Method	Description
default void	SplitEnumerator.handleSourceEvent(int subtaskId, SourceEvent sourceEvent)	Handles a custom source event from the source reader.
void	SupportsHandleExecutionAttemptSourceEvent.handleSourceEvent(int subtaskId, int attemptNumber, SourceEvent sourceEvent)	Handles a custom source event from the source reader.
default void	SourceReader.handleSourceEvents(SourceEvent sourceEvent)	Handle a custom source event sent by the SplitEnumerator.
default void	SplitEnumeratorContext.sendEventToSourceReader(int subtaskId, int attemptNumber, SourceEvent event)	Send a source event to a source reader.
void	SplitEnumeratorContext.sendEventToSourceReader(int subtaskId, SourceEvent event)	Send a source event to a source reader.
void	SourceReaderContext.sendSourceEventToCoordinator(SourceEvent sourceEvent)	Send a source event to the source coordinator.