上传者: 42131790
|
上传时间: 2022-03-24 23:45:30
|
文件大小: 59KB
|
文件类型: -
Streaming_benchmark
流基准测试旨在测量流处理系统(如flink和spark)的性能。 模拟了三个用例(用户访问会话分析,实时广告评估和购物记录分析)。 原始数据将生成并存储在Kafka中。 流映射到流表中,并且对这些表进行查询。
建造
mvn clean package
先决条件
您应该在集群中安装Apache Kafka,Apache zookeeper,Apache Spark和Blink。
设置
将项目克隆到您的母版中。
更新conf / benchmarkConf.yaml(Kafka,Zookeeper,基准测试的属性...)
streambench.zkHost ip1:2181,ip2:2181,ip3:2181...
streambench.kafka.brokerList ip