Apache Bahir分布式分析平臺覆蓋拓展

Apache Bahir 提供對分布式分析平臺（如 Apache Spark 和 Apache Flink ）的擴(kuò)展。

Apache Bahir 最初是從 Apache Spark 項(xiàng)目中提取的，現(xiàn)已經(jīng)作為一個(gè)獨(dú)立的項(xiàng)目提供，以提供不限于 Spark 相關(guān)的擴(kuò)展/插件、連接器和其他可插入組件的實(shí)現(xiàn)。通過提供多樣化的流連接器（streaming connectors）和 SQL 數(shù)據(jù)源擴(kuò)展分析平臺的覆蓋面。

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