sparkStreaming初嘗－－scala連接mysql分析

本例子是我初嘗 spark 的sparkStreaming官方小例子修改的。java 個人思路是使用jdbc 連接數據庫，而後查詢數據庫，將查詢結果生成一個RDD ，放入RDD queue，而後每次取出rdd 進行計算和過濾處理。mysql 本文結構以下： 1.sparkStreamingDemo 2.scala 連接mysql 數據庫 1.sparkStreamingDemo 因爲這個demo須

>>阅读原文<<