Flink Dynamodb as sink

[hemant singh]

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 and could not find one. If none exists, has anyone implemented one and any hints on that direction will help a lot.

Thanks,

Hemant

[容祖儿]

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 <[hidden email]> 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 and could not find one. If none exists, has anyone implemented one and any hints on that direction will help a lot.

Thanks,

Hemant

[hemant singh]

Thanks, I'll check it out. 

On Tue, Feb 4, 2020 at 12:30 PM 容祖儿 <[hidden email]> 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 <[hidden email]> 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 and could not find one. If none exists, has anyone implemented one and any hints on that direction will help a lot.

Thanks,

Hemant

[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-0D26B2B3D3EF@...%3E

Someone also proposes a skeleton of the code there.

Regards,
Timo


On 04.02.20 08:10, hemant singh wrote:

> Thanks, I'll check it out.
>
> On Tue, Feb 4, 2020 at 12:30 PM 容祖儿 <[hidden email]
> <mailto:[hidden email]>> 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 <[hidden email]
>     <mailto:[hidden email]>> 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 and could not find one. If none exists, has anyone
>         implemented one and any hints on that direction will help a lot.
>
>         Thanks,
>         Hemant
>