flink学习-DataSink学习
原创
何为sink?
sink的意思就是存储的意思，在flink流计算框架中，在获取流进行相应的数据转换和处理之后的下一步就是数据的存储了。一般就是存储到es，mysql，kafka等相应的存储数据系统中。
sinkFunction接口
一般用户自定义的sink方法都要实现sinkFunction中的invoke方法，其中sinkFunction还有一个抽象类richSinkFunction,比如自带的打印的方法就实现了这个invoke方法，他这里invoke方法的实现方式就是将数据打印出来。
使用方式：
SingleOutputStreamOperator.addSink(new PrintSinkFunction<>();//注意这里传进去的参数也可以是用户自定义的sink方法原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。
如有侵权，请联系 cloudcommunity@tencent.com 删除。
原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。
如有侵权，请联系 cloudcommunity@tencent.com 删除。
评论
作者已关闭评论
推荐阅读
目录
相关产品与服务
对象存储
对象存储（Cloud Object Storage，COS）是由腾讯云推出的无目录层次结构、无数据格式限制，可容纳海量数据且支持 HTTP/HTTPS 协议访问的分布式存储服务。腾讯云 COS 的存储桶空间无容量上限，无需分区管理，适用于 CDN 数据分发、数据万象处理或大数据计算与分析的数据湖等多种场景。