apache / seatunnel

SeaTunnel is a next-generation super high-performance, distributed, massive data integration tool.
https://seatunnel.apache.org/
Apache License 2.0
7.98k stars 1.8k forks source link

[Feature][Core] Add event notify for all connector #7501

Closed zhangshenghang closed 2 months ago

zhangshenghang commented 2 months ago

Purpose of this pull request

@Hisoka-X

1. Source-related Classes

Class Name Method Introduced Event
SourceFlowLifeCycle open ReaderOpenEvent
SourceFlowLifeCycle close ReaderCloseEvent
ParallelSource open ReaderOpenEvent
ParallelSource close ReaderCloseEvent
CoordinatedSource open ReaderOpenEvent
CoordinatedSource close ReaderCloseEvent
FlinkSourceReader start ReaderOpenEvent
FlinkSourceReader close ReaderCloseEvent

2. Enumerator-related Classes

Class Name Method Introduced Event
SourceSplitEnumeratorTask stateProcess EnumeratorOpenEvent
SourceSplitEnumeratorTask close EnumeratorCloseEvent
CoordinatedSource open EnumeratorOpenEvent
CoordinatedSource close EnumeratorCloseEvent
ParallelSource open EnumeratorOpenEvent
ParallelSource close EnumeratorCloseEvent
FlinkSourceEnumerator start EnumeratorOpenEvent
FlinkSourceEnumerator close EnumeratorCloseEvent

3. Sink-related Classes

Class Name Method Introduced Event
SinkFlowLifeCycle close WriterCloseEvent
MultiTableSinkWriter close WriterCloseEvent
FlinkSinkWriter close WriterCloseEvent
SparkDataWriter commit WriterCloseEvent
SeaTunnelSparkDataWriter commit WriterCloseEvent

Does this PR introduce any user-facing change?

How was this patch tested?

Check list