test

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;