我正在寻找一种可视化编程工具,以在创建数据流流以在 Flink 或 Beam-Flink 中构建 CEP 应用程序时抽象出编码。像 Nifi 或流数据收集器图形设计器之类的东西。
有人知道这样的项目吗?
我正在寻找一种可视化编程工具,以在创建数据流流以在 Flink 或 Beam-Flink 中构建 CEP 应用程序时抽象出编码。像 Nifi 或流数据收集器图形设计器之类的东西。
有人知道这样的项目吗?
现在有一个可视化工具https://github.com/TouK/nussknacker。它的流执行结果并没有完全映射到 Flink Operator 或 Beam,但 Nussknacker 节点可以很容易地转换为类似的 Flink Operator。一个 Nussknacker 场景被部署为单个 Flink 的工作。您还可以添加自定义组件,这些组件将更直接地转换为 Flink 的 Operators。您没有 Flink CEP 的全部功能,但您可以使用 filter/switch/split/joint 等处理许多 CEP 用例。
不幸的是,目前开源生态系统中还没有这样的可视化管道构建工具。
也就是说,这不是一个无法解决的问题——在 Apache Beam 中,它通过BEAM-266进行跟踪,并且可以想象这将成为中期项目的一部分。
在开源之外,还有一些建立在 Apache Beam 之上的商业工具可以提供类似的东西,但是在一个稍微缩小的领域(例如,数据准备)——查看 Talend、Google Cloud 和其他人的工具。