Spark处理时间序列数据

整个逻辑为： 设备端毫秒级生成数据以文本方式传输到HDFS，而后经过SPARK解析文件并存储到HBASE中。java 问题1：SPARK自己为分布式，若是经过分布式解析文件并存储，如何保证数据系列顺序？node 问题2：使用SPARK进行HBASE插入的时候，使用RddPartitionForeach，而后给每条记录生成时间戳，并插入到HBASE，发现即便是微妙级别，在foreach的时候仍然会出

>>阅读原文<<