Spark處理時間序列數據

整個邏輯爲: 設備端毫秒級生成數據以文本方式傳輸到HDFS,而後經過SPARK解析文件並存儲到HBASE中。java 問題1:SPARK自己爲分佈式,若是經過分佈式解析文件並存儲,如何保證數據系列順序?node 問題2:使用SPARK進行HBASE插入的時候,使用RddPartitionForeach,而後給每條記錄生成時間戳,並插入到HBASE,發現即便是微妙級別,在foreach的時候仍然會出
相關文章
相關標籤/搜索