开发者社区> 问答> 正文

pyflink 1.11 connector数据读取问题

目前通过 connector 定义ddl的方式,通过数据库读取数据,方式如下: CREATE TABLE MyUserTable (   id BIGINT,   name STRING,   age INT,   status BOOLEAN,   PRIMARY KEY (id) NOT ENFORCED ) WITH (    'connector' = 'jdbc',    'url' = 'jdbc:mysql://localhost:3306/mydatabase',    'table-name' = 'users' ); 每次表格获取及定义都需要定义数据类型(如例子中: BIGINT,STRING,INT,BOOLEN), 请问大佬是否有其他从数据库读取方式,可以不用定义数据类型??*来自志愿者整理的flink邮件归档

展开
收起
JACKJACK 2021-12-08 11:02:56 932 0
1 条回答
写回答
取消 提交回答
  • 对的是我!

    你好,可以写个程序自动根据表的元数据生成ddl语句*来自志愿者整理的flink邮件归档

    2021-12-08 11:22:35
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
基于 Flink SQL + Paimon 构建流式湖仓新方 立即下载
Flink Streaming SQL 2018 立即下载
spark替代HIVE实现ETL作业 立即下载