Flink kuduSink开发

1、继承RichSinkFunction （1）首先在构造方式传入kudu的masterAddress地址、默认表名、TableSerializationSchema、KuduTableRowConverter、Properties配置对象 （2）重写open方法 初始化KuduClient对象操作
posted @ 2020-05-26 19:41  码以致用  阅读(3017)  评论(0)  编辑  收藏  举报