Merge pull request #105 from DataSQRL/bump-sqrl-0.10.3

velo · web-flow · commit 1893ea6d6da7 · 2026-05-14T14:22:48.000-03:00
Bump SQRL version to 0.10.4
diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml
@@ -23,7 +23,7 @@ concurrency:
 
 env:
   TZ: 'America/Los_Angeles'
-  SQRL_VERSION: '0.9.5'
+  SQRL_VERSION: '0.10.4'
 
 jobs:
   build-and-push:
@@ -172,7 +172,7 @@ jobs:
           IMAGE="${{ inputs.sqrl_image }}"
           IS_SNAPSHOT=true
         else
-          IMAGE="datasqrl/cmd:${SQRL_VERSION}"
+          IMAGE="ghcr.io/datasqrl/cmd:${SQRL_VERSION}"
           IS_SNAPSHOT=false
         fi
         echo "image=$IMAGE" >> "$GITHUB_OUTPUT"
diff --git a/clickstream-ai-recommendation/clickstream-api/clickstream.sqrl b/clickstream-ai-recommendation/clickstream-api/clickstream.sqrl
@@ -1,3 +1,4 @@
+/*+ engine(kafka) */
 CREATE TABLE Clickstream (
     url STRING NOT NULL,
     userid STRING NOT NULL,
diff --git a/clickstream-ai-recommendation/clickstream-kafka/clickstream.sqrl b/clickstream-ai-recommendation/clickstream-kafka/clickstream.sqrl
diff --git a/clickstream-ai-recommendation/content-api/.nodiscovery b/clickstream-ai-recommendation/content-api/.nodiscovery
diff --git a/clickstream-ai-recommendation/content-api/content.sqrl b/clickstream-ai-recommendation/content-api/content.sqrl
@@ -1,6 +1,7 @@
+/*+ engine(kafka) */
 CREATE TABLE Content (
     url STRING NOT NULL,
     title STRING NOT NULL,
     text STRING NOT NULL,
     update_time TIMESTAMP_LTZ(3) NOT NULL METADATA FROM 'timestamp'
-)
+);
diff --git a/clickstream-ai-recommendation/content-kafka/content.sqrl b/clickstream-ai-recommendation/content-kafka/content.sqrl
diff --git a/clickstream-ai-recommendation/recommendation.sqrl b/clickstream-ai-recommendation/recommendation.sqrl
@@ -1,8 +1,8 @@
 /*+no_query */
-IMPORT clickstream-{{variant}}.clickstream;
+IMPORT clickstream-{{variant}}.clickstream.*;
 
 /*+no_query */
-IMPORT content-{{variant}}.content;
+IMPORT content-{{variant}}.content.*;
 
 /* Find next page visits within 10 minutes */
 _CoVisits := SELECT b.url AS beforeURL, a.url AS afterURL,
diff --git a/finance-credit-card-chatbot/credit-card-views/creditcard_views.sqrl b/finance-credit-card-chatbot/credit-card-views/creditcard_views.sqrl
@@ -8,7 +8,6 @@ _Merchant       := DISTINCT _MerchantStream ON merchantId ORDER BY updatedTime D
 _CardAssignment := DISTINCT _CardAssignmentStream ON cardNo ORDER BY `timestamp` DESC;
 
 /* Enrich credit card transactions with customer and merchant information */
-/*+partition_key(customerId) */
 _CustomerTransaction := SELECT t.transactionId, t.cardNo, t.`time`, t.amount,
                               m.category, c.customerId, m.merchantId
                        FROM _Transaction t
diff --git a/healthcare-study/healthcare-study-api/metrics-api/clinical_indicator.sqrl b/healthcare-study/healthcare-study-api/metrics-api/clinical_indicator.sqrl
@@ -1,5 +1,6 @@
-CREATE TABLE ClinicalIndicator (
+/*+ engine(kafka) */
+CREATE TABLE AddClinicalData (
    sensorId BIGINT NOT NULL,
    metric DOUBLE NOT NULL,
    `timestamp` TIMESTAMP_LTZ(3) NOT NULL METADATA FROM 'timestamp'
-);
+);
diff --git a/healthcare-study/healthcare-study-api/metrics-testdata/clinical_indicator.avsc b/healthcare-study/healthcare-study-api/metrics-testdata/clinical_indicator.avsc
diff --git a/healthcare-study/healthcare-study-api/metrics-testdata/clinical_indicator.sqrl b/healthcare-study/healthcare-study-api/metrics-testdata/clinical_indicator.sqrl
@@ -1,9 +1,9 @@
-CREATE TABLE ClinicalIndicator (
+CREATE TABLE AddClinicalData (
      `timestamp` AS TO_TIMESTAMP_LTZ(`time`,3),
      WATERMARK FOR `timestamp` AS `timestamp` - INTERVAL '0.001' SECOND
 ) WITH (
       'format' = 'flexible-json',
       'path' = '${DATA_PATH}/clinical_indicator.jsonl',
       'source.monitor-interval' = '10 min',
       'connector' = 'filesystem'
-) LIKE `clinical_indicator.avsc`;
+) LIKE `clinical_indicator.jsonl`;
diff --git a/healthcare-study/healthcare-study-api/study_api.sqrl b/healthcare-study/healthcare-study-api/study_api.sqrl
@@ -1,7 +1,7 @@
 IMPORT study-testdata.* AS _CDC_;
 
-/*+no_query */
-IMPORT metrics-{{variant}}.clinical_indicator AS AddClinicalData;
+/*+ no_query */
+IMPORT metrics-{{variant}}.clinical_indicator.*;
 
 _ClinicalIndicator := SELECT sensorId, metric, `timestamp` FROM AddClinicalData;
 
diff --git a/iot-sensor-metrics/sensors-api/readings.sqrl b/iot-sensor-metrics/sensors-api/readings.sqrl
@@ -1,4 +1,5 @@
-CREATE TABLE Readings (
+/*+ engine(kafka) */
+CREATE TABLE SensorReading (
    sensorid INT NOT NULL,
    temperature decimal(8,2) NOT NULL,
    event_time TIMESTAMP_LTZ(3) NOT NULL METADATA FROM 'timestamp'
diff --git a/iot-sensor-metrics/sensors-testdata/readings.jsonl b/iot-sensor-metrics/sensors-testdata/readings.jsonl
@@ -7,7 +7,7 @@
 {"sensorid": 2, "temperature": 12.7, "event_time": "2024-10-16T22:53:55.390Z"}
 {"sensorid": 2, "temperature": 14.7, "event_time": "2024-10-16T22:53:55.383Z"}
 {"sensorid": 2, "temperature": 110.1, "event_time": "2024-10-16T22:53:55.376Z"}
-{"sensorid": 2, "temperature": 105.7, "event_time": "2024-10-16T22:53:47.029Z"}
+{"sensorid": 2, "temperature": 106.7, "event_time": "2024-10-16T22:53:47.029Z"}
 {"sensorid": 2, "temperature": 80.5, "event_time": "2024-10-16T22:53:47.023Z"}
 {"sensorid": 3, "temperature": 112.3, "event_time": "2024-10-16T22:53:55.388Z"}
 {"sensorid": 3, "temperature": 88.5, "event_time": "2024-10-16T22:53:55.380Z"}
diff --git a/iot-sensor-metrics/sensors-testdata/readings.sqrl b/iot-sensor-metrics/sensors-testdata/readings.sqrl
@@ -0,0 +1,3 @@
+CREATE TABLE SensorReading (
+   WATERMARK FOR `event_time` AS `event_time` - INTERVAL '0.001' SECOND
+) LIKE `readings.jsonl`;
diff --git a/iot-sensor-metrics/sensors-testdata/readings.table.sql b/iot-sensor-metrics/sensors-testdata/readings.table.sql
diff --git a/iot-sensor-metrics/sensors.sqrl b/iot-sensor-metrics/sensors.sqrl
@@ -1,5 +1,5 @@
 /*+no_query*/
-IMPORT sensors-{{variant}}.readings AS SensorReading;
+IMPORT sensors-{{variant}}.readings.*;
 
 /**
  Returns all sensor temperature readings above the given temperature
diff --git a/iot-sensor-metrics/snapshots-api/SensorHighTempTest.snapshot b/iot-sensor-metrics/snapshots-api/SensorHighTempTest.snapshot
@@ -2,7 +2,7 @@
   "data" : {
     "SensorHighTempTest" : [ {
       "num" : 5,
-      "avg_temp" : 106.0
+      "avg_temp" : 106.2
     } ]
   }
 }
diff --git a/iot-sensor-metrics/snapshots-api/hightemp_subscription.snapshot b/iot-sensor-metrics/snapshots-api/hightemp_subscription.snapshot
@@ -16,7 +16,7 @@
   "data" : {
     "HighTemp" : {
       "sensorid" : 2,
-      "temperature" : 105.7
+      "temperature" : 106.7
     }
   }
 }, {
diff --git a/iot-sensor-metrics/snapshots-api/readingsbytemp-query.snapshot b/iot-sensor-metrics/snapshots-api/readingsbytemp-query.snapshot
@@ -8,7 +8,7 @@
       "temperature" : 110.1
     }, {
       "sensorid" : 2,
-      "temperature" : 105.7
+      "temperature" : 106.7
     }, {
       "sensorid" : 1,
       "temperature" : 101.5
diff --git a/iot-sensor-metrics/snapshots-testdata/SensorHighTempTest.snapshot b/iot-sensor-metrics/snapshots-testdata/SensorHighTempTest.snapshot
@@ -2,7 +2,7 @@
   "data" : {
     "SensorHighTempTest" : [ {
       "num" : 5,
-      "avg_temp" : 106.0
+      "avg_temp" : 106.2
     } ]
   }
 }
diff --git a/iot-sensor-metrics/tests-api/addreading1-mutation.graphql b/iot-sensor-metrics/tests-api/addreading1-mutation.graphql
@@ -1,17 +1,17 @@
 mutation {
-    AddReading1: Readings(event: {sensorid: 1, temperature: 101.5}) {
+    AddReading1: SensorReading(event: {sensorid: 1, temperature: 101.5}) {
         sensorid
     }
-    AddReading2: Readings(event: {sensorid: 2, temperature: 80.5}) {
+    AddReading2: SensorReading(event: {sensorid: 2, temperature: 80.5}) {
         sensorid
     }
-    AddReading3: Readings(event: {sensorid: 3, temperature: 60.2}) {
+    AddReading3: SensorReading(event: {sensorid: 3, temperature: 60.2}) {
         sensorid
     }
-    AddReading4: Readings(event: {sensorid: 2, temperature: 105.7}) {
+    AddReading4: SensorReading(event: {sensorid: 2, temperature: 106.7}) {
         sensorid
     }
-    AddReading5: Readings(event: {sensorid: 1, temperature: 73.4}) {
+    AddReading5: SensorReading(event: {sensorid: 1, temperature: 73.4}) {
         sensorid
     }
 }
diff --git a/iot-sensor-metrics/tests-api/addreading2-mutation.graphql b/iot-sensor-metrics/tests-api/addreading2-mutation.graphql
@@ -1,26 +1,26 @@
 mutation {
-    AddReading1: Readings(event: {sensorid: 1, temperature: 13.5}) {
+    AddReading1: SensorReading(event: {sensorid: 1, temperature: 13.5}) {
         temperature
     }
-    AddReading2: Readings(event: {sensorid: 2, temperature: 110.1}) {
+    AddReading2: SensorReading(event: {sensorid: 2, temperature: 110.1}) {
         temperature
     }
-    AddReading3: Readings(event: {sensorid: 3, temperature: 88.5}) {
+    AddReading3: SensorReading(event: {sensorid: 3, temperature: 88.5}) {
         temperature
     }
-    AddReading4: Readings(event: {sensorid: 2, temperature: 14.7}) {
+    AddReading4: SensorReading(event: {sensorid: 2, temperature: 14.7}) {
         temperature
     }
-    AddReading5: Readings(event: {sensorid: 1, temperature: 100.4}) {
+    AddReading5: SensorReading(event: {sensorid: 1, temperature: 100.4}) {
         temperature
     }
-    AddReading6: Readings(event: {sensorid: 3, temperature: 112.3}) {
+    AddReading6: SensorReading(event: {sensorid: 3, temperature: 112.3}) {
         temperature
     }
-    AddReading7: Readings(event: {sensorid: 2, temperature: 12.7}) {
+    AddReading7: SensorReading(event: {sensorid: 2, temperature: 12.7}) {
         temperature
     }
-    AddReading8: Readings(event: {sensorid: 1, temperature: 43.2}) {
+    AddReading8: SensorReading(event: {sensorid: 1, temperature: 43.2}) {
         temperature
     }
 }
diff --git a/law-enforcement/baseball_card.sqrl b/law-enforcement/baseball_card.sqrl
@@ -80,7 +80,7 @@ WarrantsTest := SELECT warrant_status, COUNT(1) AS num_warrants
 
 /* License plate tracking and alerting */
 
-/*+no_query*/
+/*+ engine(kafka), no_query*/
 CREATE TABLE Tracking (
    plate STRING NOT NULL,
    latitude decimal(8,3) NOT NULL,
diff --git a/oil-gas-agent-automation/oil-gas-agent-operations/operations_agent.sqrl b/oil-gas-agent-automation/oil-gas-agent-operations/operations_agent.sqrl
@@ -2,7 +2,7 @@ IMPORT oilgas-{{variant}}.assets AS _AssetUpdates;
 IMPORT oilgas-{{variant}}.maintenance AS _MaintenanceUpdates;
 IMPORT oilgas-{{variant}}.measurement AS _Measurement;
 
-/*+no_query */
+/*+ no_query, engine(kafka) */
 CREATE TABLE FlowRate (
     event_id STRING NOT NULL METADATA FROM 'uuid',
     assetId BIGINT NOT NULL,
diff --git a/test-jobs/failure-tests/udfs/FailingFunction.java b/test-jobs/failure-tests/udfs/FailingFunction.java
@@ -1,4 +1,5 @@
 ///usr/bin/env jbang "$0" "$@" ; exit $?
+//DEPS org.apache.flink:flink-table-common:2.2.0
 
 import org.apache.flink.table.functions.FunctionContext;
 import org.apache.flink.table.functions.ScalarFunction;
diff --git a/usage-analytics/usertokens-api/user_tokens.sqrl b/usage-analytics/usertokens-api/user_tokens.sqrl
@@ -1,3 +1,4 @@
+/*+ engine(kafka) */
 CREATE TABLE UserTokens (
     `userid` BIGINT NOT NULL,
     `tokens` BIGINT NOT NULL,
diff --git a/usage-analytics/usertokens-testdata/user_tokens.sqrl b/usage-analytics/usertokens-testdata/user_tokens.sqrl
diff --git a/usage-analytics/usertokens.sqrl b/usage-analytics/usertokens.sqrl
@@ -1,5 +1,5 @@
 /*+no_query */
-IMPORT usertokens-{{variant}}.user_tokens;
+IMPORT usertokens-{{variant}}.user_tokens.*;
 
 _TokenUsageHourWindow := SELECT userid, window_start, window_end, window_time,
                                 SUM(tokens) AS total_tokens
diff --git a/user-defined-function/jbang/myudf.sqrl b/user-defined-function/jbang/myudf.sqrl
@@ -1,6 +1,7 @@
 IMPORT usrlib.MyScalarFunction;
 
 -- Capture some input data
+/*+engine(kafka) */
 CREATE TABLE InputData (
     val BIGINT NOT NULL
 );
diff --git a/user-defined-function/jbang/usrlib/MyScalarFunction.java b/user-defined-function/jbang/usrlib/MyScalarFunction.java
@@ -1,4 +1,5 @@
 ///usr/bin/env jbang "$0" "$@" ; exit $?
+//DEPS org.apache.flink:flink-table-common:2.2.0
 
 import org.apache.flink.table.functions.ScalarFunction;
 
diff --git a/user-defined-function/maven-project/myudf.sqrl b/user-defined-function/maven-project/myudf.sqrl
@@ -4,6 +4,7 @@
 IMPORT myjavafunction.target.MyScalarFunction;
 
 -- Capture some input data
+/*+engine(kafka) */
 CREATE TABLE InputData (
     val BIGINT NOT NULL
 );

Original file line number	Diff line number	Diff line change
`@@ -1,3 +1,4 @@`
	`1`	`+/+ engine(kafka) /`
`1`	`2`	`CREATE TABLE Clickstream (`
`2`	`3`	`url STRING NOT NULL,`
`3`	`4`	`userid STRING NOT NULL,`