Apache StreamPipes Apache StreamPipes（正在孵化）通过在现有流处理框架之上提供图形化建模编辑器，实现了对流处理管道的灵活建模。 它使非技术用户能够基于易于扩展的数据源，数据处理器和数据接收器工具箱，快速定义和执行处理管道。 StreamPipes具有可交换的运行时执行层，并使用提供的包装器之一（例如，独立的或分布在Apache Flink中）执行管道。 StreamPipes中的管道元素可以在运行时安装-内置的SDK可以根据您的需求轻松实现新的管道元素。