Copy input to destination

Add the payload as data, e.g.

$.data VARCHAR(256000)



CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (event_data VARCHAR(256000));
CREATE OR REPLACE  PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM"
SELECT STREAM "data" AS "event_data"
FROM "SOURCE_SQL_STREAM_001";
-- Uses a 10-second tumbling time window
--GROUP BY FLOOR(("SOURCE_SQL_STREAM_001".ROWTIME - TIMESTAMP '1970-01-01 00:00:00') SECOND / 10 TO SECOND);