开发者社区> 问答> 正文

Flink 1.10 PyFlink支持中间表吗?

哪位大佬知道Flink 1.10 PyFlink支持中间表 或者支持这种写法吗 source = st_env.scan("source_kafka_ifang_dkt_log") dim_table = source.select("cluster, caller, cid,content, ip path, type") st_env.register_table('dim_table', dim_table)

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

展开
收起
游客sadna6pkvqnz6 2021-12-07 17:33:22 948 0
1 条回答
写回答
取消 提交回答
  • 支持的,你试试*来自志愿者整理的flink

    2021-12-07 21:22:02
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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