Remove timezone form timestamp

Author: velo

src/test/docker/docker-compose.yml

@@ -22,7 +22,7 @@ networks:
 
 services:
   postgres:
-    image: postgres:16
+    image: postgres:17
     environment:
       POSTGRES_USER: postgres
       POSTGRES_PASSWORD: postgres

src/test/resources/sqrl/compiled-plan.json

@@ -16,7 +16,7 @@
               "dataType" : "DOUBLE NOT NULL"
             }, {
               "name" : "time",
-              "dataType" : "TIMESTAMP(3) WITH LOCAL TIME ZONE NOT NULL"
+              "dataType" : "TIMESTAMP NOT NULL"
             }, {
               "name" : "amount",
               "dataType" : "DOUBLE NOT NULL"
@@ -43,7 +43,7 @@
         }
       }
     },
-    "outputType" : "ROW<`transactionId` BIGINT NOT NULL, `cardNo` DOUBLE NOT NULL, `time` TIMESTAMP(3) WITH LOCAL TIME ZONE NOT NULL, `amount` DOUBLE NOT NULL, `merchantId` BIGINT NOT NULL>",
+    "outputType" : "ROW<`transactionId` BIGINT NOT NULL, `cardNo` DOUBLE NOT NULL, `time` TIMESTAMP NOT NULL, `amount` DOUBLE NOT NULL, `merchantId` BIGINT NOT NULL>",
     "description" : "TableSourceScan(table=[[default_catalog, default_database, _transaction_1]], fields=[transactionId, cardNo, time, amount, merchantId])",
     "inputProperties" : [ ]
   }, {
@@ -60,7 +60,7 @@
     }, {
       "kind" : "INPUT_REF",
       "inputIndex" : 2,
-      "type" : "TIMESTAMP(3) WITH LOCAL TIME ZONE NOT NULL"
+      "type" : "TIMESTAMP NOT NULL"
     } ],
     "condition" : null,
     "inputProperties" : [ {
@@ -70,7 +70,7 @@
       "damBehavior" : "PIPELINED",
       "priority" : 0
     } ],
-    "outputType" : "ROW<`merchantId` BIGINT NOT NULL, `amount` DOUBLE NOT NULL, `time` TIMESTAMP(3) WITH LOCAL TIME ZONE NOT NULL>",
+    "outputType" : "ROW<`merchantId` BIGINT NOT NULL, `amount` DOUBLE NOT NULL, `time` TIMESTAMP NOT NULL>",
     "description" : "Calc(select=[merchantId, amount, time])"
   }, {
     "id" : 3,
@@ -83,7 +83,7 @@
       "damBehavior" : "PIPELINED",
       "priority" : 0
     } ],
-    "outputType" : "ROW<`merchantId` BIGINT NOT NULL, `amount` DOUBLE NOT NULL, `time` TIMESTAMP(3) WITH LOCAL TIME ZONE NOT NULL>",
+    "outputType" : "ROW<`merchantId` BIGINT NOT NULL, `amount` DOUBLE NOT NULL, `time` TIMESTAMP NOT NULL>",
     "description" : "Exchange(distribution=[hash[merchantId]])"
   }, {
     "id" : 4,
@@ -110,7 +110,7 @@
       "distinct" : false,
       "approximate" : false,
       "ignoreNulls" : false,
-      "type" : "TIMESTAMP(3) WITH LOCAL TIME ZONE NOT NULL"
+      "type" : "TIMESTAMP NOT NULL"
     } ],
     "aggCallNeedRetractions" : [ false, false ],
     "generateUpdateBefore" : false,
@@ -127,7 +127,7 @@
       "damBehavior" : "PIPELINED",
       "priority" : 0
     } ],
-    "outputType" : "ROW<`merchantId` BIGINT NOT NULL, `max_amount` DOUBLE NOT NULL, `__timestamp` TIMESTAMP(3) WITH LOCAL TIME ZONE NOT NULL>",
+    "outputType" : "ROW<`merchantId` BIGINT NOT NULL, `max_amount` DOUBLE NOT NULL, `__timestamp` TIMESTAMP NOT NULL>",
     "description" : "GroupAggregate(groupBy=[merchantId], select=[merchantId, MAX(amount) AS max_amount, MAX(time) AS __timestamp])"
   }, {
     "id" : 5,
@@ -147,7 +147,7 @@
     }, {
       "kind" : "INPUT_REF",
       "inputIndex" : 2,
-      "type" : "TIMESTAMP(3) WITH LOCAL TIME ZONE NOT NULL"
+      "type" : "TIMESTAMP NOT NULL"
     } ],
     "condition" : null,
     "inputProperties" : [ {
@@ -157,7 +157,7 @@
       "damBehavior" : "PIPELINED",
       "priority" : 0
     } ],
-    "outputType" : "ROW<`merchantId` BIGINT NOT NULL, `double_ta` INT NOT NULL, `max_amount` DOUBLE NOT NULL, `__timestamp` TIMESTAMP(3) WITH LOCAL TIME ZONE NOT NULL>",
+    "outputType" : "ROW<`merchantId` BIGINT NOT NULL, `double_ta` INT NOT NULL, `max_amount` DOUBLE NOT NULL, `__timestamp` TIMESTAMP NOT NULL>",
     "description" : "Calc(select=[merchantId, 2 AS double_ta, max_amount, __timestamp])"
   }, {
     "id" : 6,
@@ -185,7 +185,7 @@
               "dataType" : "DOUBLE NOT NULL"
             }, {
               "name" : "__timestamp",
-              "dataType" : "TIMESTAMP(3) WITH LOCAL TIME ZONE NOT NULL"
+              "dataType" : "TIMESTAMP NOT NULL"
             } ],
             "watermarkSpecs" : [ ],
             "primaryKey" : {
@@ -214,7 +214,7 @@
       "damBehavior" : "PIPELINED",
       "priority" : 0
     } ],
-    "outputType" : "ROW<`merchantId` BIGINT NOT NULL, `double_ta` INT NOT NULL, `max_amount` DOUBLE NOT NULL, `__timestamp` TIMESTAMP(3) WITH LOCAL TIME ZONE NOT NULL>",
+    "outputType" : "ROW<`merchantId` BIGINT NOT NULL, `double_ta` INT NOT NULL, `max_amount` DOUBLE NOT NULL, `__timestamp` TIMESTAMP NOT NULL>",
     "description" : "Sink(table=[default_catalog.default_database.transactionbymerchant_1], fields=[merchantId, double_ta, max_amount, __timestamp])"
   } ],
   "edges" : [ {

src/test/resources/sqrl/postgres-schema.sql

@@ -1,3 +1,4 @@
-CREATE TABLE IF NOT EXISTS transactionbymerchant_1 ("merchantId" BIGINT NOT NULL,"double_ta" DOUBLE PRECISION NOT NULL,"max_amount" DOUBLE PRECISION NOT NULL,"__timestamp" TIMESTAMP WITH TIME ZONE NOT NULL , PRIMARY KEY ("merchantId"));
+CREATE TABLE IF NOT EXISTS transactionbymerchant_1 ("merchantid" BIGINT NOT NULL,"double_ta" DOUBLE PRECISION NOT NULL,"max_amount" DOUBLE PRECISION NOT NULL,"__timestamp" TIMESTAMP 
+ NOT NULL , PRIMARY KEY ("merchantid"));