Re: Flink Dynamodb as sink

2020-02-04 Thread Timo Walther
Hi Hemant, maybe this thread from last year could also help you: http://mail-archives.apache.org/mod_mbox/flink-user/201903.mbox/%3c2df93e1c-ae46-47ca-9c62-0d26b2b3d...@gmail.com%3E Someone also proposes a skeleton of the code there. Regards, Timo On 04.02.20 08:10, hemant singh wrote: Than

Re: Flink Dynamodb as sink

2020-02-03 Thread hemant singh
Thanks, I'll check it out. On Tue, Feb 4, 2020 at 12:30 PM 容祖儿 wrote: > you can customize a Sink function (implement SinkFunction) that's not so > hard. > > regards. > > On Tue, Feb 4, 2020 at 2:38 PM hemant singh wrote: > >> Hi All, >> >> I am using dynamodb as a sink for one of the metrics pi

Re: Flink Dynamodb as sink

2020-02-03 Thread 容祖儿
you can customize a Sink function (implement SinkFunction) that's not so hard. regards. On Tue, Feb 4, 2020 at 2:38 PM hemant singh wrote: > Hi All, > > I am using dynamodb as a sink for one of the metrics pipeline. Wanted to > understand if there are any existing connectors. I did searched an