开发者社区> 问答> 正文

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 520 0
1 条回答
写回答
取消 提交回答
  • 我猜哈,是因为source支持多张表。比如多个表union支持select的情况*来自志愿者整理的FLINK邮件归档

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

相关电子书

更多
Get rid of traditional ETL, Move to Spark! 立即下载
File Format Benchmark- Avro, J 立即下载
From Zero to Data Flow In Hours with Apache Nifi 立即下载