[NSE-1034] Add timeZoneId in ColumnarUnixTimestamp

native-sql-engine/core/src/main/scala/com/intel/oap/expression/ColumnarBinaryExpression.scala

@@ -121,7 +121,7 @@ object ColumnarBinaryExpression {
       case s: DateDiff =>
         new ColumnarDateDiff(left, right)
       case a: UnixTimestamp =>
-        new ColumnarUnixTimestamp(left, right)
+        new ColumnarUnixTimestamp(left, right, a.timeZoneId, a.failOnError)
       // To match GetTimestamp (a private class).
       case _ if (original.isInstanceOf[ToTimestamp] && original.dataType == TimestampType) =>
         // Convert a string to Timestamp. Default timezone is used.

native-sql-engine/core/src/main/scala/com/intel/oap/expression/ColumnarDateTimeExpressions.scala

@@ -445,8 +445,12 @@ object ColumnarDateTimeExpressions {
     * The input is the date/time for local timezone (can be configured in spark) and the result is
     * the timestamp for UTC. So we need consider timezone difference.
     * */
-  class ColumnarUnixTimestamp(left: Expression, right: Expression)
-      extends UnixTimestamp(left, right) with
+  class ColumnarUnixTimestamp(
+      left: Expression,
+      right: Expression,
+      timeZoneId: Option[String] = None,
+      failOnError: Boolean = SQLConf.get.ansiEnabled)
+      extends UnixTimestamp(left, right, timeZoneId, failOnError) with
       ColumnarExpression {
 
     val yearMonthDayFormat = "yyyy-MM-dd"