... 需要設定檢查點位置 ssc.checkpoint("/tmp/sparkstreaming/") val stream = ssc.socketTextStream("localhost", 9999) //從原始文字元素建立事件串流 val events ...
確定! 回上一頁