使用ProM和Apache Beam处理数据流
该库包含将Apache Beam(一种流处理框架)与ProM(一种由科学家用于设计和测试过程挖掘算法)的框架集成在一起的示例。
实现了两个示例:Alpha Miner从Kafka读取数据,使用Beams内置的窗口机制,将Alpha miner算法应用于每个窗口中的数据,并将结果作为xml保存回kafka。
第二个示例Fuzzy Miner,使用了不同的过程挖掘技术,而不是以文本格式保存结果,而是将过程可视化并将结果保存为png图像到kafka。
该库还包含一个工具箱(demo_data目录),该工具箱包含用于配置测试Apache Kafka实例并用一些演示数据填充它的脚本。
要求
可以使用ant ( )和ivy ( )构建系统。
快速开始
在alpha_miner目录中使用ant命令构建alpha alpha_miner 。
通过
2021-11-05 23:40:25
35KB
Java
1