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

[Benchao Li <li...@apache.org>]

Hi Ada,

这应该就是一个实现上的失误：

1.
source的名字是calcite的`TableScan#explainTerms`里面实现的，用的是`explainTerms(pw).item("table",
this.table.getQualifiedName())`
2.
sink里的名字是flink里的`Sink#explainTerms`实现的，用的是`.explainTerms(pw).item("table",
tableIdentifier.asSummaryString())`

yidan zhao <hi...@gmail.com> 于2021年9月30日周四 上午11:43写道：

> 我猜哈，是因为source支持多张表。比如多个表union支持select的情况。
>
> Ada Luna <gf...@gmail.com> 于2021年9月29日周三 下午6:02写道：
>
> > Source: TableSourceScan(table=[[default_catalog, default_database,
> > 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相比多了个 中括号，并且采用 ',' 分割名字功空间，这是为什么
> >
>


-- 

Best,
Benchao Li