问题标签 [apache-bahir]

问问题

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

22 问题
Newest
Active
Bountied
318
Unanswered
0 投票
1 回答
74 浏览

java - 具有 groupId `org.apache.bahir` 和 `org.apache.flink` 的两个 Flink Redis sink 依赖项有什么区别？

我正在学习 Flink。我尝试添加一个 Redis 接收器。在官方 Flink 文档中，它链接到Apache Bahir 文档，该文档正在使用

但是，我flink-connector-redis在Maven找到了另一个：

如您所见，这groupId是不同的。

我在他们的网站上找到了有关 Apache Bahir 的信息。

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

目前，Bahir 为 Apache Spark 和 Apache Flink 提供扩展。

这两个依赖有什么区别？建议先使用哪一个？谢谢！

0 投票
1 回答
118 浏览

scala - java.lang.ClassNotFoundException：找不到数据源：org.apache.bahir.sql.streaming.mqtt.MQTTStreamSinkProvider。请找包

我已经添加了

到我的build.sbt，并使用

在代码中，但得到


12345678910