Fix bug of merge_session timestamps

OMNILab · Dec 28, 2015 · cfb9500 · cfb9500
1 parent dcb00a3
commit cfb9500
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/etlers/WifiToolkit/src/main/scala/cn/edu/sjtu/omnilab/odh/spark/MergeWifiSession.scala b/etlers/WifiToolkit/src/main/scala/cn/edu/sjtu/omnilab/odh/spark/MergeWifiSession.scala
@@ -1,6 +1,7 @@
 package cn.edu.sjtu.omnilab.odh.spark
 
 import cn.edu.sjtu.omnilab.odh.rawfilter.{APToBuilding, WIFICode}
+import cn.edu.sjtu.omnilab.odh.utils.Utils
 import org.apache.commons.lang.StringUtils
 import org.apache.spark.{SparkContext, SparkConf}
 import org.apache.spark.SparkContext._ // to use join etc.
@@ -67,7 +68,7 @@ object MergeWifiSession {
 
           CleanWIFILog(
             MAC = parts(0),
-            time = parts(1).toLong,
+            time = Utils.ISOToUnix(parts(1)),
             code = parts(2).toInt,
             payload = parts(3)
           )