Thank you, I will try that. On Sun, Jan 29, 2023, 9:01 PM Benchao Li <[email protected]> wrote:
> 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 >
