calcite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 陈江枫 <>
Subject testStreamGroupByHaving of InfiniteStreamTable
Date Sun, 26 Feb 2017 09:21:26 GMT
Hi, Calcite experts

I'm interested in streaming sql,

in org.apache.calcite.test.StreamTest

If I execute the query "select stream floor(rowtime to hour) as
rowtime, product,
count(*) as c from orders group by floor(rowtime to hour), product having
count(*) > 1"

upon InfiniteOrdersTable implementation, the program just blocked, results
won't come out, however OrdersTable worked just fine, but it's finite
streams of table.

Not sure how to integrate infinite streams with Calcite to make streaming
sql work.could someone help?

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message