From 93b7ff8f863f89e59de831887e145a818354e7ce Mon Sep 17 00:00:00 2001 From: povconfluent Date: Tue, 8 Mar 2022 16:22:40 +0100 Subject: [PATCH] test --- docker/data/mqtt.ksql | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docker/data/mqtt.ksql b/docker/data/mqtt.ksql index ed6792e..ac5befb 100644 --- a/docker/data/mqtt.ksql +++ b/docker/data/mqtt.ksql @@ -34,7 +34,7 @@ SELECT TIMESTAMPTOSTRING(TST*1000, 'MMM-dd HH:mm:ss','Europe/London') as TS, GEO_DISTANCE(LAT,LON,51.4965005,-0.2106881,'KM') AS DISTANCE_FROM_VENUE FROM MQTT_RAW emit changes; -SELECT who, SPLIT(WHO, '/')[2] AS WHO2 FROM MQTT_RAW EMIT CHANGES LIMIT 5; +SELECT who, SPLIT(WHO, '/')[3] AS WHO2 FROM MQTT_RAW EMIT CHANGES LIMIT 5; SELECT LAT, LON, CAST(LAT AS VARCHAR) + ',' + CAST(LON AS VARCHAR) AS LOCATION FROM MQTT_RAW EMIT CHANGES LIMIT 5;