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

Add support for DDB Streams for DataStream API

    XMLWordPrintableJSON

Details

    Description

       

      In the legacy KDS source we support Amazon DynamoDB streams via an adapter shim. Both KDS and DDB streams have a similar API.

      This task builds upon https://issues.apache.org/jira/browse/FLINK-34339 and will add a DynamoDBStreamsSource which will setup a DDB SDK client shim.

      Attachments

        Issue Links

          blocks

          Sub-task - The sub-task of the issue FLINK-34342 Address Shard Consistency Issue for DDB Streams Source

          • Major - Major loss of function.
          • Resolved

          New Feature - A new feature of the product, which has yet to be developed. FLINK-34340 Implement DDB Streams Table API support

          • Major - Major loss of function.
          • Open
          links to

          Web Link GitHub Pull Request #146

          Activity

            People

              gguptp Abhi Gupta
              dannycranmer Danny Cranmer
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: