开发者社区> 问答> 正文

FlinkSQL Source和Sink的Operator name为什么格式不同


ods_k]], fields=[id, name])

Sink: Sink(table=[default_catalog.default_database.ads_k], fields=[id, name])

Sink: Sink(table=[default_catalog.default_database.ads_k2], fields=[id, name]))





TableSourceScan 和 Sink相比多了个 中括号,并且采用 ',' 分割名字功空间,这是为什么*来自志愿者整理的flink邮件归档

展开
收起
彗星halation 2021-12-02 16:46:28 521 0
1 条回答
写回答
取消 提交回答
  • 我猜哈,是因为source支持多张表。比如多个表union支持select的情况*来自志愿者整理的FLINK邮件归档

    2021-12-02 16:59:29
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Apache Phoenix and HBase: Past, Present and Future of SQL over HBase 立即下载
From Zero to Data Flow In Hours with Apache Nifi 立即下载
Scaling 30 TB\'s of Data lake with Apache HBase and Scala DSL at Production 立即下载