Flink处理kafka数据 之 分流操作 1.创建flink环境 2.创建流 3.分流操作 4.存储到对应topic 5.开启任务 --------------------...
发简信
IP属地：江苏
-
Flink处理kafka实时流数据
-
Spark on k8s: 通过hostPath设置SPARK_LOCAL_DIRS加速Shuffle前言 spark.local.dir/SPARK_LOCAL_DIRS 用于Spark 在 Shuffle阶段临时文件及RDD持久化存储等，可以使用逗号分隔配置多个路径对应到...
-
fastjson序列化将null变成空字符串
fastjson默认将null的key去掉，由于记录日志需要字段必须是全的，所以让fastjson序列化的时候将null变成空字符串
-
Elasticsearch Java API的基本使用
说明 在明确了ES的基本概念和使用方法后，我们来学习如何使用ES的Java API.本文假设你已经对ES的基本概念已经有了一个比较全面的认识。 客户端 你可以用Java客户端...
