Update examples to DataSQRL 0.8 (#76)

Author: ferenc-csaky

.github/workflows/build.yml

@@ -47,7 +47,6 @@ jobs:
             test_commands: |
               compile -c study_analytics_package_test.json
               test -c study_analytics_package_test.json
-            # FIXME https://github.com/DataSQRL/sqrl/issues/1140 compile -c study_analytics_package_snowflake.json
           - example: healthcare-study-api
             path: healthcare-study/healthcare-study-api
             tag: healthcare-study-api
@@ -152,8 +151,6 @@ jobs:
         cat <<EOF > ${{ matrix.path }}/Dockerfile
         FROM datasqrl/cmd:${SQRL_VERSION}
 
-        ENV TZ="UTC"
-
         COPY . /build
         WORKDIR /build
         EOF

clickstream-ai-recommendation/clickstream-api/clickstream.table.sql

@@ -1,5 +1,5 @@
-CREATE TABLE AddClick (
+CREATE TABLE Clickstream (
     url STRING NOT NULL,
     userid STRING NOT NULL,
     event_time TIMESTAMP_LTZ(3) NOT NULL METADATA FROM 'timestamp'
-);
+);

clickstream-ai-recommendation/clickstream-kafka/clickstream.table.sql

@@ -1,4 +1,4 @@
-CREATE TABLE AddClick (
+CREATE TABLE Clickstream (
     url STRING NOT NULL,
     userid STRING NOT NULL,
     event_time TIMESTAMP_LTZ(3) NOT NULL METADATA FROM 'timestamp',
@@ -11,4 +11,4 @@ CREATE TABLE AddClick (
     'scan.startup.mode' = 'group-offsets',
     'properties.auto.offset.reset' = 'earliest',
     'format' = 'flexible-json'
-      );
+);

clickstream-ai-recommendation/content-api/.nodiscovery

@@ -1,7 +1,8 @@
 /*+no_query */
-IMPORT clickstream.Clickstream;
+IMPORT clickstream-{{variant}}.clickstream;
+
 /*+no_query */
-IMPORT content.Content;
+IMPORT content-{{variant}}.content;
 
 /* Find next page visits within 10 minutes */
 _CoVisits := SELECT b.url AS beforeURL, a.url AS afterURL,

clickstream-ai-recommendation/content-api/sample_content.table.sql

@@ -1,23 +1,18 @@
 {
   "script": {
-    "main": "recommendation.sqrl"
+    "main": "recommendation.sqrl",
+    "config": {
+      "variant": "api"
+    }
+  },
+  "compiler" : {
+    "logger": "print"
   },
   "engines": {
     "flink" : {
       "config" : {
         "table.exec.source.idle-timeout": "5 s"
       }
     }
-  },
-  "compiler" : {
-    "logger": "print"
-  },
-  "dependencies": {
-    "content" : {
-      "folder": "content-api"
-    },
-    "clickstream" : {
-      "folder": "clickstream-api"
-    }
   }
 }

clickstream-ai-recommendation/recommendation.sqrl

@@ -1,6 +1,9 @@
 {
   "script": {
-    "main": "recommendation.sqrl"
+    "main": "recommendation.sqrl",
+    "config": {
+      "variant": "kafka"
+    }
   },
   "compiler" : {
     "logger": "kafka"
@@ -12,14 +15,6 @@
       }
     }
   },
-  "dependencies": {
-    "content" : {
-      "folder": "content-kafka"
-    },
-    "clickstream" : {
-      "folder": "clickstream-kafka"
-    }
-  },
   "test-runner": {
     "create-topics": ["content", "clickstream"]
   }