Apache Bahir 为多个分布式分析平台(如 Apache Spark 和 Apache Flink )提供扩展,通过各种流连接器和 SQL 数据源扩展其范围。

Apache Bahir 2.3.2 为 Apache Spark 2.3.2 提供了以下扩展:

  • Apache CouchDB/Cloudant SQL data source

  • Apache CouchDB/Cloudant Streaming connector

  • Akka Streaming connector

  • Akka Structured Streaming data source

  • Google Cloud Pub/Sub Streaming connector

  • Cloud PubNub Streaming connector (new)

  • MQTT Streaming connector

  • MQTT Structured Streaming data source (new sink)

  • Twitter Streaming connector

  • ZeroMQ Streaming connector (new enhanced implementation)

下载地址: