《表1 集群节点分布信息:基于Flink框架的TopN堆排序优化算法》
实验搭建的集群是由两台PC组成,由分布式队列Kafka作为数据源点生产数据,Flink提供FlinkKafkaConsumer接口从Kafka取数据,交给后面的operator来处理。用TaskManager节点构建整个算子拓扑,将计算结果保存在HDFS中,以Zookeeper作为集群的同步协调节点负责分布式节点间的信息同步。集群分布情况如表1所示。
图表编号 | XD00124813900 严禁用于非法目的 |
---|---|
绘制时间 | 2020.02.10 |
作者 | 关沫、魏碧晴 |
绘制单位 | 沈阳工业大学信息科学与工程学院、沈阳工业大学信息科学与工程学院 |
更多格式 | 高清、无水印(增值服务) |