Apache Bahir分布式分析平台覆盖拓展

联合创作 · 2023-10-01 07:01

Apache Bahir 提供对分布式分析平台(如 Apache SparkApache Flink )的扩展。

Apache Bahir 最初是从 Apache Spark 项目中提取的,现已经作为一个独立的项目提供,以提供不限于 Spark 相关的扩展/插件、连接器和其他可插入组件的实现。通过提供多样化的流连接器(streaming connectors)和 SQL 数据源扩展分析平台的覆盖面。

Apache Spark 拓展

  • Spark Structured Streaming data source for MQTT

  • Spark DStream connector for Akka

  • Spark DStream connector for MQTT

  • Spark DStream connector for Twitter

  • Spark DStream connector for ZeroMQ

Apache Flink 拓展

  • Flink connector for ActiveMQ

  • Flink connector for Flume

  • Flink connector for Redis

浏览 4
点赞
评论
收藏
分享

手机扫一扫分享

编辑
举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

编辑
举报