Skip to content

Instantly share code, notes, and snippets.

@miguno
Last active December 20, 2017 22:32
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save miguno/20801cb321f050ec7d3bb08706a8a7a8 to your computer and use it in GitHub Desktop.
Save miguno/20801cb321f050ec7d3bb08706a8a7a8 to your computer and use it in GitHub Desktop.
DESCRIBE EXTENDED example output
ksql> DESCRIBE EXTENDED ip_sum;
Type : TABLE
Key field : CLICKSTREAM.IP
Timestamp field : Not set - using <ROWTIME>
Key format : STRING
Value format : JSON
Kafka output topic : IP_SUM (partitions: 4, replication: 1)
Field | Type
-------------------------------------
ROWTIME | BIGINT (system)
ROWKEY | VARCHAR(STRING) (system)
IP | VARCHAR(STRING) (key)
KBYTES | BIGINT
-------------------------------------
Queries that write into this TABLE
-----------------------------------
id:CTAS_IP_SUM - CREATE TABLE IP_SUM as SELECT ip, SUM(bytes)/1024 as kbytes
FROM CLICKSTREAM WINDOW SESSION (300 SECONDS) GROUP BY ip;
For query topology and execution plan please run: EXPLAIN <QueryId>
Local runtime statistics
------------------------
messages-per-sec: 4.41 total-messages: 486 last-message: 12/14/17 4:32:23 PM GMT
failed-messages: 0 last-failed: n/a
(Statistics of the local KSQL Server interaction with the Kafka topic IP_SUM)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment