val topic ssc 數據 DStream Receiver streaming
updateStateByKey mapWithState 返回 數據量 DStream checkpoint Define