update event_time (SimpleEvent_V1.scala), add date utils

spark/src/main/scala/com/yen/eventCreator/SimpleEvent_V1.scala

@@ -3,7 +3,7 @@ package com.yen.eventCreator
 import java.io.PrintWriter
 import java.net.ServerSocket
 import java.util.Random
-import java.time.LocalDateTime
+import java.time.{LocalDateTime, LocalTime}
 
 import com.google.gson.Gson
 
@@ -27,7 +27,7 @@ object SimpleEvent_V1 extends App {
   val listener = new ServerSocket(port)
   println(s"Listening on port: $port")
 
-  case class simpleEvent(id: Int, event_date: Long, msg: String)
+  case class simpleEvent(id: Int, event_date: String, msg: String)
 
   while (true) {
     val socket = listener.accept()
@@ -40,7 +40,8 @@ object SimpleEvent_V1 extends App {
 
           val r = scala.util.Random
           val id = r.nextInt(10000000)
-          val event_date = System.currentTimeMillis
+          //val event_date = System.currentTimeMillis
+          val event_date = LocalDateTime.now()
 
           val someRandom = r.nextInt(10)
 
@@ -50,7 +51,7 @@ object SimpleEvent_V1 extends App {
             case _ => "wazzup ?"
           }
 
-          val payload = new simpleEvent(id, event_date, msg)
+          val payload = new simpleEvent(id, event_date.toString, msg)
 
           Thread.sleep(sleepDelayMs)
           val msgDataJson = new Gson().toJson(payload)

spark/src/main/scala/com/yen/utils/DateUtils.scala

@@ -0,0 +1,18 @@
+package com.yen.utils
+
+import org.joda.time.{DateTime, DateTimeZone}
+import org.joda.time.format.{DateTimeFormat, DateTimeFormatter, ISODateTimeFormat}
+
+object DateUtils {
+  // datetime format
+  val yyyyMMFormat: DateTimeFormatter = DateTimeFormat.forPattern("yyyyMM")
+  val yyyyMMddFormat: DateTimeFormatter = DateTimeFormat.forPattern("yyyyMMdd")
+  val yyyyMMddHHFormat: DateTimeFormatter = DateTimeFormat.forPattern("yyyyMMddHH")
+
+  // time zone
+  val dateFormatTaipei: DateTimeFormatter = DateTimeFormat.forPattern("yyyyMMdd").withZone(DateTimeZone.forID("Asia/Taipei"))
+
+  // iso time
+  val ISO8601Format: DateTimeFormatter = ISODateTimeFormat.dateTime()
+}
+