说明
Flink自定义Sink需要建议继承 RichSinkFunction 类
/**
* 继承RichSinkFunction<String>类，其中String为source端传到sink的数据类型
*/
public class CouponSink extends RichSinkFunction<String> {
/**
* open方法在sink第一次启动时调用，一般用于sink的初始化操作
*/
@Override
public void open(Configuration parameters) throws Exception {
super.open(parameters);
}
/**
* invoke方法是sink数据处理逻辑的方法，source端传来的 每一条数据都在invoke方法中进行处理
* 第一个参数类型与RichSinkFunction<String>中的泛型对应。
* 第二个参数为一些上下文信息
*/
@Override
public void invoke(String value, Context context) throws Exception {
System.out.println(value);
}
/**
* close方法在sink结束时调用，一般用于资源的回收操作
*/
@Override
public void close() throws Exception {
super.close();
}
}
参考
https://blog.csdn.net/gxd520/article/details/92768829