Hi Fanbin, I'm not familiar with table module. Maybe someone else could help.
@jincheng sun <sunjincheng...@gmail.com> Do you know there is any plan for kinesis table connector? Thanks, Biao /'bɪ.aʊ/ On Sat, 24 Aug 2019 at 02:26, Fanbin Bu <fanbin...@coinbase.com> wrote: > Hi, > > Looks like Flink table connectors do not include `kinesis`. (only > FileSystem, Kafka, ES) see > https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/connect.html#table-connectors > . > I also found some examples for Kafka: > https://eventador.io/blog/flink_table_and_sql_api_with_apache_flink_16/. > I'm wondering is there such a thing for kinesis also. > > Is there any plan to support this in the future? Otherwise, what needs to > be done if we want to implement it on my own. > > Basically, I have a kinesis stream that emits json string data and I would > like to use Flink Table/SQL api to to the streaming/batch processing. > Currently, I'm using DataStream API which is not as flexible. > > Any help would be appreciated. > > Thanks, > Fanbin >
