开发者社区> 问答> 正文

flink创建Sink表的方法是什么?

flink创建Sink表的方法是什么?

展开
收起
游客qzzytmszf3zhq 2021-12-07 20:26:57 428 0
1 条回答
写回答
取消 提交回答
  • CREATE TABLE flink_do_so_master (
    name VARCHAR,
    age BIGINT,
    som_sysno VARCHAR,
    PRIMARY KEY (name,som_sysno) NOT ENFORCED
    ) WITH (
       'connector' = 'adbpg',
       'url' = 'jdbc:postgresql://xxx:5432/test',
       'tablename' = 'xxx',
       'username' = 'xx',
       'password' = 'xx',
       'maxretrytimes' = '2',
       'batchsize' = '100',
       'connectionmaxactive' = '5',
       'conflictmode' = 'upsert',
       'usecopy' = '0',
       'targetschema' = 'test',
       'exceptionmode' = 'ignore',
       'casesensitive' = '0',
       'writemode' = '2',
       'retrywaittime' = '200'
    )
    
    2021-12-07 20:27:10
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载