org.apache.flink.api.connector.source

Interface SourceEvent

All Superinterfaces:

Serializable

All Known Implementing Classes:

DynamicFilteringEvent, SourceReaderFinishedEvent, SwitchSourceEvent

@Public
public interface SourceEvent
extends Serializable

An base class for the events passed between the SourceReaders and Enumerators.