Hi Vignesh, AFAIK, there is no such way in Calcite to declare it with DDL. However, you can provide it via the statistic for your table, you can take a look at the tests[1] in Calcite how we did it.
[1] https://github.com/apache/calcite/blob/ae228f64347cc7620d28eff04f5869583c6bf9d5/testkit/src/main/java/org/apache/calcite/test/catalog/MockCatalogReaderSimple.java#L238-L245 Vignesh <[email protected]> 于2023年1月30日周一 06:21写道： > 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. > -- Best, Benchao Li
