Spark處理時間序列數據

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

>>阅读原文<<