flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jamie Grier (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-4391) Provide support for asynchronous operations over streams
Date Sat, 13 Aug 2016 14:14:20 GMT
Jamie Grier created FLINK-4391:

             Summary: Provide support for asynchronous operations over streams
                 Key: FLINK-4391
                 URL: https://issues.apache.org/jira/browse/FLINK-4391
             Project: Flink
          Issue Type: New Feature
          Components: DataStream API
            Reporter: Jamie Grier

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

This message was sent by Atlassian JIRA

View raw message