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?
