开发者社区> 问答> 正文

flink sqlUpdate,如何获取里面的字段,字段类型,with 等3个属性

我用flink 注册一张表: CREATE TABLE dim_mysql ( id int, -- type varchar -- ) WITH ( 'connector' = 'jdbc', 'url' = 'jdbc:mysql://localhost:3390/test', 'table-name' = 'flink_test', 'driver' = 'com.mysql.cj.jdbc.Driver', 'username' = '', 'password' = '', 'lookup.cache.max-rows' = '5000', 'lookup.cache.ttl' = '1s', 'lookup.max-retries' = '3' ) 有没有通过 tableEnv 去获取,字段[id,type] 类型[INTEGER,VARCHAR] 以及属性,map<String,String> 这种。 我看阿里官方有blink 支持自定义sink: publicabstractclassCustomSinkBaseimplementsSerializable{ protectedMap<String,String> userParamsMap;// 您在sql with语句中定义的键值对,但所有的键均为小写 protectedSet primaryKeys;// 您定义的主键字段名 protectedList headerFields;// 标记为header的字段列表 protectedRowTypeInfo rowTypeInfo;// 字段类型和名称 核心需求是:获取定义的表的所有属性,自己实现自己的功能,包括 join sink 等各种逻辑

*来自志愿者整理的flink邮件归档

展开
收起
小阿矿 2021-12-06 15:13:36 1146 0
1 条回答
写回答
取消 提交回答
  • tableEnv 中 可以通过

    tableEvn.from(xx).getSchema() 拿到该表的schema信息,但是没法拿到对应的properties。

    如果要拿到properties,可以通过catalog的接口得到 [1]。

    如果要自定义实现source/sink,可以参考 [2]

    [1]

    https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/table/catalogs.html

    [2]

    https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/table/sourceSinks.html

    *来自志愿者整理的flink邮件归档

    2021-12-06 16:57:20
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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