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

Packages that use SourceEvent

Package	Description
org.apache.flink.api.connector.source
org.apache.flink.connector.base.source.hybrid
org.apache.flink.connector.base.source.reader
org.apache.flink.connector.file.src.impl
org.apache.flink.connector.testutils.source.reader
org.apache.flink.connectors.hive
org.apache.flink.runtime.source.coordinator
org.apache.flink.runtime.source.event
org.apache.flink.table.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 and Description
void	SupportsHandleExecutionAttemptSourceEvent.handleSourceEvent(int subtaskId, int attemptNumber, SourceEvent sourceEvent) Handles a custom source event from the source reader.
default void	SplitEnumerator.handleSourceEvent(int subtaskId, 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.

Uses of SourceEvent in org.apache.flink.connector.base.source.hybrid

Classes in org.apache.flink.connector.base.source.hybrid that implement SourceEvent

Modifier and Type	Class and Description
class	SourceReaderFinishedEvent A source event sent from the HybridSourceReader to the enumerator to indicate that the current reader has finished and splits for the next reader can be sent.
class	SwitchSourceEvent Event sent from HybridSourceSplitEnumerator to HybridSourceReader to switch to the indicated reader.

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

Modifier and Type	Method and Description
void	HybridSourceSplitEnumerator.handleSourceEvent(int subtaskId, SourceEvent sourceEvent)
void	HybridSourceReader.handleSourceEvents(SourceEvent sourceEvent)

Uses of SourceEvent in org.apache.flink.connector.base.source.reader

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

Modifier and Type	Method and Description
void	SourceReaderBase.handleSourceEvents(SourceEvent sourceEvent)

Uses of SourceEvent in org.apache.flink.connector.file.src.impl

Methods in org.apache.flink.connector.file.src.impl with parameters of type SourceEvent

Modifier and Type	Method and Description
void	DynamicFileSplitEnumerator.handleSourceEvent(int subtaskId, int attemptNumber, SourceEvent sourceEvent)
void	StaticFileSplitEnumerator.handleSourceEvent(int subtaskId, SourceEvent sourceEvent)
void	DynamicFileSplitEnumerator.handleSourceEvent(int subtaskId, SourceEvent sourceEvent)
void	ContinuousFileSplitEnumerator.handleSourceEvent(int subtaskId, SourceEvent sourceEvent)

Uses of SourceEvent in org.apache.flink.connector.testutils.source.reader

Methods in org.apache.flink.connector.testutils.source.reader that return types with arguments of type SourceEvent

Modifier and Type	Method and Description
List<SourceEvent>	TestingReaderContext.getSentEvents()
Map<Integer,List<SourceEvent>>	TestingSplitEnumeratorContext.getSentEvents()

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

Modifier and Type	Method and Description
void	TestingSplitEnumeratorContext.sendEventToSourceReader(int subtaskId, int attemptNumber, SourceEvent event)
void	TestingSplitEnumeratorContext.sendEventToSourceReader(int subtaskId, SourceEvent event)
void	TestingReaderContext.sendSourceEventToCoordinator(SourceEvent sourceEvent)

Uses of SourceEvent in org.apache.flink.connectors.hive

Methods in org.apache.flink.connectors.hive with parameters of type SourceEvent

Modifier and Type	Method and Description
void	ContinuousHiveSplitEnumerator.handleSourceEvent(int subtaskId, SourceEvent sourceEvent)

Uses of SourceEvent in org.apache.flink.runtime.source.coordinator

Methods in org.apache.flink.runtime.source.coordinator with parameters of type SourceEvent

Modifier and Type	Method and Description
void	SourceCoordinatorContext.sendEventToSourceReader(int subtaskId, int attemptNumber, SourceEvent event)
void	SourceCoordinatorContext.sendEventToSourceReader(int subtaskId, SourceEvent event)

Uses of SourceEvent in org.apache.flink.runtime.source.event

Methods in org.apache.flink.runtime.source.event that return SourceEvent

Modifier and Type	Method and Description
SourceEvent	SourceEventWrapper.getSourceEvent()

Constructors in org.apache.flink.runtime.source.event with parameters of type SourceEvent

Constructor and Description
SourceEventWrapper(SourceEvent sourceEvent)

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

Classes in org.apache.flink.table.connector.source that implement SourceEvent

Modifier and Type	Class and Description
class	DynamicFilteringEvent A source event to transport the DynamicFilteringData for dynamic filtering purpose.