Skip to content

Instantly share code, notes, and snippets.

@apurvam

apurvam/table-aggregations.sql

Last active April 28, 2018 17:53
Show Gist options
  • Save apurvam/319f507e76d240061b2a94fac67a11ae to your computer and use it in GitHub Desktop.
Save apurvam/319f507e76d240061b2a94fac67a11ae to your computer and use it in GitHub Desktop.
Download ZIP
Example of table aggregations in KSQL
Raw
table-aggregations.sql
CREATE TABLE users (userid bigint, zipcode int, created_at bigint) \
WITH (kafka_topic=’users’, value_format=’json’, key=’userid’);
SELECT zipcode, count(*) from users GROUP BY zipcode;
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment