Add a UT

oap-project · Aug 11, 2022 · 96afc65 · 96afc65
1 parent f447e28
commit 96afc65
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/native-sql-engine/core/src/test/scala/com/intel/oap/misc/DateTimeSuite.scala b/native-sql-engine/core/src/test/scala/com/intel/oap/misc/DateTimeSuite.scala
@@ -785,6 +785,19 @@ class DateTimeSuite extends QueryTest with SharedSparkSession {
         Seq(Row(java.lang.Long.valueOf(1248940800L)),
           Row(java.lang.Long.valueOf(1249027200L)),
           Row(java.lang.Long.valueOf(1249113600L))))
+
+      // Test date format: yyyyMMdd
+      val datesNoSep = Seq("20090730", "20090731", "20090801")
+        .map(s => Tuple1(s)).toDF("time")
+      datesNoSep.createOrReplaceTempView("dates_no_sep")
+      val frameNoSep = sql("SELECT unix_timestamp(time, 'yyyyMMdd') FROM dates_no_sep")
+      assert(frameNoSep.queryExecution.executedPlan.find(p => p
+        .isInstanceOf[ColumnarConditionProjectExec]).isDefined)
+      checkAnswer(
+        frameNoSep,
+        Seq(Row(java.lang.Long.valueOf(1248940800L)),
+          Row(java.lang.Long.valueOf(1249027200L)),
+          Row(java.lang.Long.valueOf(1249113600L))))
     }
   }
 }