flink在校验DDL属性是否合格时候代码在哪里?

classic Classic list List threaded Threaded
2 messages Options
kcz
Reply | Threaded
Open this post in threaded view
|

flink在校验DDL属性是否合格时候代码在哪里?

kcz
自己写类似的,有太多的if 嵌套了,想学习下,模仿下。
Reply | Threaded
Open this post in threaded view
|

Re: flink在校验DDL属性是否合格时候代码在哪里?

Leonard Xu
HI

> 在 2020年9月26日,13:26,kcz <[hidden email]> 写道:
>
> 自己写类似的,有太多的if 嵌套了,想学习下,模仿下。

DDL的属性是指WITH里面的属性吗?这个是各个connector校验的,具体的代码在可以先看下各个connector的实现,参考:
DynamicTableSourceFactory DynamicTableSinkFactory 的实现类, 比如:JdbcDynamicTableFactory

祝好
Leonard