Finance credit card chatbot analytics s3

finance-credit-card-chatbot/credit-card-analytics/creditcard-s3/cardassignment.table.sql

@@ -0,0 +1,12 @@
+CREATE TABLE CardAssignment (
+    customerId BIGINT NOT NULL,
+    cardNo STRING NOT NULL,
+    cardType STRING NOT NULL,
+    `timestamp` TIMESTAMP_LTZ(3) NOT NULL METADATA FROM 'timestamp',
+    WATERMARK FOR `timestamp` AS `timestamp` - INTERVAL '1' SECOND
+) WITH (
+      'connector' = 'filesystem',
+      'format' = 'flexible-json',
+      'path' = 's3://example-data.dev.datasqrl.com/mvp/cardAssignment.jsonl',
+      'source.monitor-interval' = '1 min'
+      );

finance-credit-card-chatbot/credit-card-analytics/creditcard-s3/merchant.table.sql

@@ -0,0 +1,12 @@
+CREATE TABLE Merchant (
+    merchantId BIGINT NOT NULL,
+    name STRING NOT NULL,
+    category STRING NOT NULL,
+    updatedTime TIMESTAMP_LTZ(3) NOT NULL  METADATA FROM 'timestamp',
+    WATERMARK FOR `updatedTime` AS `updatedTime` - INTERVAL '1' SECOND
+) WITH (
+    'connector' = 'filesystem',
+    'format' = 'flexible-json',
+    'path' = 's3://example-data.dev.datasqrl.com/mvp/merchant.jsonl',
+    'source.monitor-interval' = '1 min'
+    );

finance-credit-card-chatbot/credit-card-analytics/creditcard-s3/merchantreward.table.sql

@@ -0,0 +1,16 @@
+CREATE TABLE MerchantReward (
+    merchantId BIGINT NOT NULL,
+    rewardsByCard ARRAY<ROW<
+            cardType STRING,
+            rewardPercentage BIGINT,
+            startTimestamp BIGINT,
+            expirationTimestamp BIGINT
+        >> NOT NULL,
+    updatedTime TIMESTAMP_LTZ(3) NOT NULL METADATA FROM 'timestamp',
+    WATERMARK FOR `updatedTime` AS `updatedTime` - INTERVAL '1' SECOND
+) WITH (
+    'connector' = 'filesystem',
+    'format' = 'flexible-json',
+    'path' = 's3://example-data.dev.datasqrl.com/mvp/merchantReward.jsonl',
+    'source.monitor-interval' = '1 min'
+    );

finance-credit-card-chatbot/credit-card-analytics/creditcard-s3/transaction.table.sql

@@ -0,0 +1,13 @@
+CREATE TABLE Transaction (
+    transactionId BIGINT NOT NULL,
+    cardNo STRING NOT NULL,
+    `time` TIMESTAMP_LTZ(3) NOT NULL METADATA FROM 'timestamp',
+    amount DOUBLE NOT NULL,
+    merchantId BIGINT NOT NULL,
+    WATERMARK FOR `time` AS `time` - INTERVAL '1' SECOND
+) WITH (
+      'connector' = 'filesystem',
+      'format' = 'flexible-json',
+      'path' = 's3://example-data.dev.datasqrl.com/mvp/transaction.jsonl',
+      'source.monitor-interval' = '1 min'
+      );

finance-credit-card-chatbot/credit-card-analytics/creditcard_analytics_package_s3.json

@@ -0,0 +1,23 @@
+{
+    "version": "1",
+    "enabled-engines": [
+        "vertx",
+        "postgres",
+        "flink"
+    ],
+    "script": {
+        "main": "creditcard_analytics.sqrl"
+    },
+    "engines": {
+        "flink": {
+            "config": {
+                "table.exec.source.idle-timeout": "10 s"
+            }
+        }
+    },
+    "dependencies": {
+        "creditcard-data": {
+            "folder": "creditcard-s3"
+        }
+    }
+}