sparkStreaming初尝--scala连接mysql分析

本例子是我初尝 spark 的sparkStreaming官方小例子修改的。java 个人思路是使用jdbc 连接数据库,而后查询数据库,将查询结果生成一个RDD ,放入RDD queue,而后每次取出rdd 进行计算和过滤处理。mysql 本文结构以下: 1.sparkStreamingDemo 2.scala 连接mysql 数据库 1.sparkStreamingDemo 因为这个demo须
相关文章
相关标签/搜索