在Centos7上基于Zookeeper实现Flink1.13.2的高可用HA搭建(Standalone和Yarn版本)
目录 1. 安装规划 2. 下载解压(在bigdata001操作) 3. Standalone模式...
不点
2022-06-06 14:18:43阅读：130
-
-
Flink Maven项目准备、key的定义、DataSet的数据源
目录 1. Maven项目准备 2. 使用字段表达式为groupBy定义嵌套数据类型的Key 3. DataSet API的数...
访客 2022-06-06 14:18:37阅读：122 -
Flink DataSet聚合、分区、排序、关联转换算子的使用
目录 1. 聚合转换算子 1.1 reduce 1.2 aggregate 1.3...
访客 2022-06-06 14:18:29阅读：123 -
Flink分布式缓存和广播变量的讲解
目录 1. 分布式缓存 2. 广播变量 1. 分布式缓存 readTextFile.txt文件内容：...
访客 2022-06-06 14:18:20阅读：123 -
Flink的数据类型和序列化(Scala版)
目录 1. 数据类型 1.1 Tuple和case class 1.2 POJOs类...
java哥 2022-06-06 14:18:09阅读：122 -
Flink生成执行计划图并进行可视化
打开执行计划图Web界面 复制println(senv.getExecutionPlan)打印的执行计划JOSN 粘贴，然后点击Draw按钮，如下图所示...
熊孩纸 2022-06-06 14:17:58阅读：126 -
向Flink传递自定义参数的3种方式(withParameters、setGlobalJobParameters、ParameterTool)
目录 1. devBase\WithParameters.scala 2. devBase\GlobalJobParameters.s...
访客 2022-06-06 14:17:50阅读：123 -
Flink Accumulators累加器、Counters计数器的使用和实现自定义Accumulators、Counters
目录 1. 自定义Accumulators 2. Accumulators的使用 3. 内置的Accumulators...
阿里 2022-06-06 14:17:48阅读：127 -
Flink DataStream的wordCount、数据源和Sink、Side Outputs、两阶段提交(two-phase commit, 2PC)
目录 1. pom.xml的依赖 2. 使用DataStream实现word count 2.1 不...
符号 2022-06-06 14:17:42阅读：123 -
Flink DataStream的多流、键控流、窗口、连接、物理分区转换算子的使用
目录 1. 多流转换算子 1.1 union 1.2 connect 2....
无情 2022-06-06 14:17:37阅读：124
