from(bucket: "mydb")  |> range(start: -1h)  |> filter(fn: (r) => r["_measurement"] == "mymeasurement")  |> map(fn: (r) => ({ r with value: r.value * 2 }))  |> filter(fn: (r) => r.value > 100)  |> aggregateWindow(every: 1m, fn: sum, createEmpty: false)  |> group(columns: ["location"])  |> join(tables: {stream1: {bucket: "mydb", measurement: "stream1", start: -1h}, stream2: {bucket: "mydb", measurement: "stream2", start: -1h}}, on: ["location"])  |> alert(name: "value_above_threshold", message: "Value is above threshold", crit: (r) => r.value > 100)  |> to(bucket: "mydb", measurement: "output", tagColumns: ["location"])

CREATE STREAM current_stream        TRIGGER AT_ONCE        INTO current_stream_output_stb AS        SELECT              _wstart as start,               _wend as end,               max(current) as max_current         FROM meters         WHERE voltage <= 220         INTEVAL (5S) SLIDING (1s);