[FLINK-29944] Support accumulator in source reader

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.17.0
• Component/s: API / DataStream
• Labels: auto-deprioritized-critical pull-request-available

Docs Text

link
https://github.com/apache/flink/pull/21258

• Assignee: Unassigned
• Reporter: hk__lrzy
• Created: 09/Nov/22 03:28
• Updated: 19/Aug/23 22:35

Description

Source Reader is mainly for union batch and streaming logic in single interface, it's good point for the developer, but in the SourceFunction we can access runtimeconext to use accumulator before, now the SourceReaderContext have no method for it, this PR is mainly to support it.

Issue Links

• links to: github issue