Hi,

This page <https://calcite.apache.org/docs/stream.html> describes streaming
queries in calcite.
Streaming operators, such as tumbling window require a monotonic column. It
says that we need to declare monotonic columns in the schema.

Is there a way to do it in the create table statement? Flink SQL does it
with a "WATERMARK FOR rowtime_column"
<https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/create/#create-table>
syntax in the create table, but that seems to be flink specific.


Thanks,
Vignesh.

Reply via email to