Iot Kinesis SQL

IotKinesisSql

CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (time_stamp bigint, mean_value double);
CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM"
SELECT STREAM 
MAX("COL_timestamp") OVER TEN_SECOND_SLIDING_WINDOW as time_stamp,
AVG(cast("v" as double)) OVER TEN_SECOND_SLIDING_WINDOW AS mean_value
FROM "SOURCE_SQL_STREAM_001"
WHERE "id" = 'Simulation Examples.Functions.Sine4'
WINDOW TEN_SECOND_SLIDING_WINDOW AS (
  PARTITION BY "COL_timestamp"
  RANGE INTERVAL '10' SECOND PRECEDING);