Apache源码分析-阿里云

【Flink】（05）Apache Flink 漫谈系列 —— SocketWindowWordCount 程序执行过程源码分析3

4.4 reduce 转换reduce转换的入参是一个ReduceFunction的具体实现，这里的逻辑就是对收到的WordWithCount实例集合，将其中word字段相同的实际的count值累加。public SingleOutputStreamOperator<T> reduce(...

【Flink】（05）Apache Flink 漫谈系列 —— SocketWindowWordCount 程序执行过程源码分析2

四、操作数据流进行具体的转换操作：DataStream<WordWithCount> windowCounts = text .flatMap(new FlatMapFunction<String, WordWithCount>() { @Override public vo...

Apache RocketMQ：如何从互联网时代演进到云

1 课时 |

154 人已学 |

加入学习

Apache Flink 入门到实战 - Flink开源社区出品

16 课时 |

1392 人已学 |

加入学习

Apache Flink 入门

9 课时 |

4826 人已学 |

加入学习

【Flink】（05）Apache Flink 漫谈系列 —— SocketWindowWordCount 程序执行过程源码分析1

文章目录一、前言二、代码部分三、构建数据源四、操作数据流4.1 flatMap 转换4.2 keyBy 转换4.3 timeWindow 转换4.4 reduce 转换五、输出统计结果一、前言本文主要是根据一段简单的 SocketWindowWordCount 代码，进而对 Flink 的执行过程进...

Apache RocketMQ中多副本之 Leader 选举的源码分析流程是怎样的？

Apache Spark Delta Lake 事务日志实现源码分析

Apache Spark Delta Lake 事务日志实现源码分析我们已经在这篇文章详细介绍了 Apache Spark Delta Lake 的事务日志是什么、主要用途以及如何工作的。那篇文章已经可以很好地给大家介绍 Delta Lake 的内部工作原理...

Apache Kafka源码分析 - kafka controller

前面已经分析过kafka server的启动过程，以及server所能处理的所有的request，即KafkaApis 剩下的，其实关键就是controller，以及partition和replica的状态机这里先看看controller在broker server的基础上...

Apache Kafka源码分析 - ReplicaStateMachine

startup 在onControllerFailover中被调用， /** * Invoked on successful controller election. First registers a broker change listener since that triggers all *...

Apache Kafka源码分析 - PartitionStateMachine

startup 在onControllerFailover中被调用， initializePartitionState private def initializePartitionState() { for((topicPartition, replicaAssignment) <- con...

Apache Kafka源码分析 - autoLeaderRebalanceEnable

在broker的配置中，auto.leader.rebalance.enable (false) 那么这个leader是如何进行rebalance的？首先在controller启动的时候会打开一个scheduler， if (config.autoLeaderRebalanceEnable) { ...