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)
下载地址: