remove line continuation chars

bokjo · Apr 12, 2019 · 1a5344b · 1a5344b
1 parent e7e2e0d
commit 1a5344b
Showing 1 changed file with 26 additions and 39 deletions.
diff --git a/gcp-pipeline/env-data/apply_schema__unify_streams.ksql b/gcp-pipeline/env-data/apply_schema__unify_streams.ksql
@@ -1,42 +1,29 @@
-CREATE STREAM ENVIRONMENT_DATA WITH \
-        (VALUE_FORMAT='AVRO') AS \
-SELECT  items->stationreference AS stationreference, \
-        items->earegionname AS earegionname, \
-        items->eaareaname AS eaareaname, \
-        items->town AS town, \
-        items->RiverName AS RiverName, \
-        items->label AS label, \
-        items->lat AS lat, items->long AS long, \
-        items->measures->latestreading->datetime AS reading_ts, \
-        items->measures->parameterName AS parameterName, \
-        items->measures->latestreading->value AS reading_ts, \
-        items->measures->unitname AS unitname \
+CREATE STREAM ENVIRONMENT_DATA WITH 
+        (VALUE_FORMAT='AVRO') AS 
+SELECT  items->stationreference AS stationreference, 
+        items->earegionname AS earegionname, 
+        items->eaareaname AS eaareaname, 
+        items->town AS town, 
+        items->RiverName AS RiverName, 
+        items->label AS label, 
+        items->lat AS lat, items->long AS long, 
+        items->measures->latestreading->datetime AS reading_ts, 
+        items->measures->parameterName AS parameterName, 
+        items->measures->latestreading->value AS value, 
+        items->measures->unitname AS unitname 
  FROM   flood_monitoring_L2404 ;
 
-INSERT INTO ENVIRONMENT_DATA \
-SELECT  items->stationreference AS stationreference, \
-        items->earegionname AS earegionname, \
-        items->eaareaname AS eaareaname, \
-        items->town AS town, \
-        items->RiverName AS RiverName, \
-        items->label AS label, \
-        items->lat AS lat, items->long AS long, \
-        items->measures->latestreading->datetime AS reading_ts, \
-        items->measures->parameterName AS parameterName, \
-        items->measures->latestreading->value AS reading_ts, \
-        items->measures->unitname AS unitname \
- FROM   flood_monitoring_L2481 ;
-
-INSERT INTO ENVIRONMENT_DATA \
-SELECT  items->stationreference AS stationreference, \
-        items->earegionname AS earegionname, \
-        items->eaareaname AS eaareaname, \
-        items->town AS town, \
-        items->RiverName AS RiverName, \
-        items->label AS label, \
-        items->lat AS lat, items->long AS long, \
-        items->measures->latestreading->datetime AS reading_ts, \
-        items->measures->parameterName AS parameterName, \
-        items->measures->latestreading->value AS reading_ts, \
-        items->measures->unitname AS unitname \
+INSERT INTO ENVIRONMENT_DATA SELECT  items->stationreference AS stationreference, items->earegionname AS earegionname, items->eaareaname AS eaareaname, items->town AS town, items->RiverName AS RiverName, items->label AS label, items->lat AS lat, items->long AS long, items->measures->latestreading->datetime AS reading_ts, items->measures->parameterName AS parameterName, items->measures->latestreading->value AS value, items->measures->unitname AS unitname FROM   flood_monitoring_L2481 ;
+INSERT INTO ENVIRONMENT_DATA 
+SELECT  items->stationreference AS stationreference, 
+        items->earegionname AS earegionname, 
+        items->eaareaname AS eaareaname, 
+        items->town AS town, 
+        items->RiverName AS RiverName, 
+        items->label AS label, 
+        items->lat AS lat, items->long AS long, 
+        items->measures->latestreading->datetime AS reading_ts, 
+        items->measures->parameterName AS parameterName, 
+        items->measures->latestreading->value AS value, 
+        items->measures->unitname AS unitname 
  FROM   flood_monitoring_059793 ;