如何在Spark-streaming中连接MySQL数据库？

Question

在JdbcRDD和DataFrames的情况下，我可以连接Mysql数据库。但是，如何在Spark-streaming中连接MySQL数据库呢？

谢谢。

Answer 1

如果您想要从MySQL表中读取数据，那么您需要根据自己的需求为其创建一个CustomReceiver。

Custom Receivers

您也可以为此编写Scala或Java代码。