如何实现 UpsertStreamTableSink , BatchTableSink 接口

Tue, 26 Mar 2019 01:55:00 -0700 

大家好！

    有没有伙伴对 blink 中 flink-table 模块下的 UpsertStreamTableSink , BatchTableSink 
这两个接口比较熟悉？或者对TableSink这块处理原理比较熟悉？我想实现这两个接口，以实现JDBC更新功能，自己看源码只能看懂表面，希望熟悉的伙伴能给些指导。。。



[email protected]

回复