目前通过 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), 请问大佬是否有其他从数据库读取方式,可以不用定义数据类型??
- pyflink 1.11 connector数据读取问题 肖越
- 回复:pyflink 1.11 connector数据读取问题 12862930