How to Filter Array Values in ksqlDB

To filter an array of measurements by removing any values under 5.6, you can:

SELECT 
  FILTER(measurements, x => x > 5.6)
FROM earthquake;

The earthquake stream was created as follows:

CREATE STREAM earthquake (
  measurements ARRAY<DOUBLE>,
) WITH (...)

Was this article helpful?