update event_date type in case class (streamSocketEventToHDFSV5, Stre…

…amFromSocket5
yennanliu · Apr 27, 2021 · ff03446 · ff03446
1 parent 99e4de0
commit ff03446
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/spark/src/main/scala/com/yen/dev/StreamFromSocket5.scala b/spark/src/main/scala/com/yen/dev/StreamFromSocket5.scala
@@ -30,7 +30,7 @@ object StreamFromSocket5 extends App {
 
   val eventSchema = StructType(List(
     StructField("id", IntegerType),
-    StructField("event_date", LongType),
+    StructField("event_date", StringType),
     StructField("msg", StringType)
   ))
 

diff --git a/spark/src/main/scala/com/yen/streamSocketToHDFS/streamSocketEventToHDFSV5.scala b/spark/src/main/scala/com/yen/streamSocketToHDFS/streamSocketEventToHDFSV5.scala
@@ -30,7 +30,7 @@ object streamSocketEventToHDFSV5 extends App {
 
   val eventSchema = StructType(List(
     StructField("id", IntegerType),
-    StructField("event_date", LongType),
+    StructField("event_date", StringType),
     StructField("msg", StringType)
   ))