This message was deleted.

How about SQL Based ingestion, here's an example of writing to one datasource while reading from another, you can adjust the schema by adjusted the SELECT portion of the statement:

INSERT INTO target_datasource
SELECT
  FLOOR(__time TO MINUTE) AS __time,
  channel,
  countryIsoCode,
  countryName,
  regionIsoCode,
  regionName,
  page,
  COUNT(*) AS cnt,
  SUM(added) AS sum_added,
  SUM(deleted) AS sum_deleted
FROM source_datasource
GROUP BY 1, 2, 3, 4, 5, 6, 7
PARTITIONED BY HOUR
CLUSTERED BY page

Thanks, will explore this