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

Provide support for asynchronous operations over streams

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 1.2.0
    • API / DataStream
    • None

    Description

      Many Flink users need to do asynchronous processing driven by data from a DataStream. The classic example would be joining against an external database in order to enrich a stream with extra information.

      It would be nice to add general support for this type of operation in the Flink API. Ideally this could simply take the form of a new operator that manages async operations, keeps so many of them in flight, and then emits results to downstream operators as the async operations complete.

      Attachments

        Issue Links

          links to

          Web Link GitHub Pull Request #2629

          Activity

            People

              david.wang david.wang
              jgrier Jamie Grier
              Votes:
              0 Vote for this issue
              Watchers:
              14 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: