Skip to main content
Version: Next

SELECT statement

Part of CREATE PUMP statement.

Fetches rows from upstreams, and processes the rows.

Syntax​

Syntax
SELECT STREAM
  <select_list>
FROM <stream_name>
     <join_clause>?
<group_by_clause>?
<window_clause>?

Example​

Example
SELECT STREAM
    FLOOR_TIME(source_trade.ts, DURATION_SECS(10)) AS min_ts,
    AVG(source_trade.amount) AS avg_amount
FROM source_trade
GROUP BY min_ts
FIXED WINDOW DURATION_SECS(10), DURATION_SECS(0);