Flink WriteRedis
pom
<dependency><groupId>org.apache.bahir</groupId><artifactId>flink-connector-redis_2.11</artifactId><version>1.0</version></dependency>
代码
package com.claroja;import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.redis.RedisSink;
import org.apache.flink.streaming.connectors.redis.common.config.FlinkJedisPoolConfig;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisCommand;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisCommandDescription;
import org.apache.flink.streaming.connectors.redis.common.mapper.RedisMapper;public class WriteToRedis {public static void main(String[] args) throws Exception {StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();env.setParallelism(1);DataStream<SensorReading> stream = env.addSource(new SensorSource());FlinkJedisPoolConfig conf = new FlinkJedisPoolConfig.Builder().setHost("localhost").build();stream.addSink(new RedisSink<SensorReading>(conf, new MyRedisSink()));env.execute();}public static class MyRedisSink implements RedisMapper<SensorReading> {@Overridepublic String getKeyFromData(SensorReading sensorReading) {return sensorReading.id;}@Overridepublic String getValueFromData(SensorReading sensorReading) {return sensorReading.temperature + "";}@Overridepublic RedisCommandDescription getCommandDescription() {return new RedisCommandDescription(RedisCommand.HSET, "sensor");}}
}
Flink WriteRedis相关推荐
- hadoop,spark,scala,flink 大数据分布式系统汇总
20220314 https://shimo.im/docs/YcPW8YY3T6dT86dV/read 尚硅谷大数据文档资料 iceberg相当于对hive的读写,starrocks相当于对mysq ...
- 2021年大数据Flink(四十八):扩展阅读 Streaming File Sink
目录 扩展阅读 Streaming File Sink 介绍 场景描述 Bucket和SubTask.PartFile 案例演示 扩展阅读 配置详解 PartFile PartFile序列化编码 ...
- 2021年大数据Flink(四十六):扩展阅读 异步IO
目录 扩展阅读 异步IO 介绍 异步IO操作的需求 使用Aysnc I/O的前提条件 Async I/O API 案例演示 扩展阅读 原理深入 AsyncDataStream 消息的顺序性 扩展阅读 ...
- 2021年大数据Flink(四十五):扩展阅读 双流Join
目录 扩展阅读 双流Join 介绍 Window Join Interval Join 代码演示1 代码演示2 重点注意 扩展阅读 双流Join 介绍 https:// ...
- 2021年大数据Flink(四十四):扩展阅读 End-to-End Exactly-Once
目录 扩展阅读 End-to-End Exactly-Once 流处理的数据处理语义 At-most-once-最多一次 At-least-once-至少一次 Exactly-once-精确一次 En ...
- 2021年大数据Flink(四十二):BroadcastState
目录 BroadcastState BroadcastState介绍 需求-实现配置动态更新 编码步骤 1.env 2.source 3.transformation 4.sink 5.e ...
- 2021年大数据Flink(四十一):Flink实现订单自动好评
目录 Flink实现订单自动好评 需求 数据 编码步骤 1.env 2.source 3.transformation 4.sink 5.execute 参考代码 参考效果 实现代码: Flink实现 ...
- 2021年大数据Flink(四十):Flink模拟双十一实时大屏统计
目录 Flink模拟双十一实时大屏统计 需求 数据 编码步骤: 1.env 2.source 3.transformation 4.使用上面聚合的结果,实现业务需求: 5.execute 参考代码 实 ...
- 2021年大数据Flink(三十九):Table与SQL 总结 Flink-SQL常用算子
目录 总结 Flink-SQL常用算子 SELECT WHERE DISTINCT GROUP BY UNION 和 UNION ALL JOI ...
最新文章
- 视频系列:RTX实时射线追踪(下)
- FileZilla Server简介及使用说明
- 上周热点回顾(12.18-12.24)
- Break,Continue,Return 傻傻分不清楚
- linux sdk 窗口句柄,Venus: 针对Linux平台上,对常用的系统API进行面向对象的封装SDK。...
- linux下C/C++ IDE比较 Code::Blocks还是不错的
- Purpose of cmove instruction in x86 assembly? | cmove 指令如何避免错误的分支预测带来的开销?
- bzoj 3611: [Heoi2014]大工程(虚树+树形DP)
- Linux入门自学笔记
- access做mysql前端,ASP+ACCESS留言板制作详细教程
- AVOD:点云数据与BEV图的处理及可视化
- 利用PowerShell把多个文件压缩打包
- 语音控制Office,这个功能一定要体验
- 对一个文件夹下的图片进行批量缩放(resize)处理
- 超赞!每个设计师都应该了解的IOS编年史
- 智能取餐柜----解锁外卖新姿势
- 【tio-core】1、tio-study是学习t-io的第一步
- 目前CSDN上最全面的C语言讲解如何用更高层次编写嵌入式C代码
- qss 画框_PyQt5系列教程(77):QSS入门2
- 同花顺行情服务器在哪个文件夹,同花顺的文件目录(文件结构)
热门文章
- 【原】 图片预览 Image preview
- python头文件库_跟老齐学Python之不要红头文件(1)
- 一文掌握Python集合的语法与应用
- 学习Python的好去处,微信公众号“Python小屋”
- ajax js引用,ajax 引用js文件内容
- db2如何锁定一张表_DB2数据库为单个会话锁定的技巧
- 4.3【图像镜像】-------------基于Opencv实现-----图像的镜像变换
- LINUX下的GNU调试工具,GNU调试器 GDB 8.3 发布及安装更新,支持RISC-V与IPv6连接等
- 手写 Promise.all
- 数学对编程思想的帮助_学编程需要什么基础?