Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-11875

Enhance stream operator API to support selective reading and EndOfInput event

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.9.0
    • Component/s: Runtime / Task
    • Labels:
      None

      Description

      Towards the goal that unify Streaming and Batch, this jira proposes enhanced stream operator api to support selective reading and EndOfInput event for currently Batch’s requirements.

      Design Doc

      Discussion Mail

        Attachments

        There are no Sub-Tasks for this issue.

          Activity

            People

            • Assignee:
              sunhaibotb Haibo Sun
              Reporter:
              sunhaibotb Haibo Sun
            • Votes:
              0 Vote for this issue
              Watchers:
              12 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 3h 40m
                3h 40m