diff --git a/docs/dev/table/functions.md b/docs/dev/table/functions.md index 682f519eb3ce6..f41139d14957c 100644 --- a/docs/dev/table/functions.md +++ b/docs/dev/table/functions.md @@ -3573,7 +3573,18 @@ NUMERIC.years

Creates an interval of months for NUMERIC years.

- + + + {% highlight java %} +NUMERIC.quarter +NUMERIC.quarters +{% endhighlight %} + + +

Creates an interval of months for NUMERIC quarters.

+

E.g., 2.quarters returns 6.

+ + {% highlight java %} @@ -3586,6 +3597,19 @@ NUMERIC.months + + + {% highlight java %} +NUMERIC.week +NUMERIC.weeks +{% endhighlight %} + + +

Creates an interval of milliseconds for NUMERIC weeks.

+

E.g., 2.weeks returns 1209600000.

+ + + {% highlight java %} @@ -3831,6 +3855,19 @@ NUMERIC.years + + + {% highlight scala %} +NUMERIC.quarter +NUMERIC.quarters +{% endhighlight %} + + +

Creates an interval of months for NUMERIC quarters.

+

E.g., 2.quarters returns 6.

+ + + {% highlight scala %} @@ -3843,6 +3880,19 @@ NUMERIC.months + + + {% highlight scala %} +NUMERIC.week +NUMERIC.weeks +{% endhighlight %} + + +

Creates an interval of milliseconds for NUMERIC weeks.

+

E.g., 2.weeks returns 1209600000.

+ + + {% highlight scala %} diff --git a/docs/dev/table/tableApi.md b/docs/dev/table/tableApi.md index e44df24ad5ec9..d44eebddf5351 100644 --- a/docs/dev/table/tableApi.md +++ b/docs/dev/table/tableApi.md @@ -109,7 +109,7 @@ Table orders = tEnv.scan("Orders"); // schema (a, b, c, rowtime) Table result = orders .filter("a.isNotNull && b.isNotNull && c.isNotNull") - .select("a.lowerCase(), b, rowtime") + .select("a.lowerCase() as a, b, rowtime") .window(Tumble.over("1.hour").on("rowtime").as("hourlyWindow")) .groupBy("hourlyWindow, a") .select("a, hourlyWindow.end as hour, b.avg as avgBillingAmount"); @@ -128,7 +128,7 @@ val orders: Table = tEnv.scan("Orders") // schema (a, b, c, rowtime) val result: Table = orders .filter('a.isNotNull && 'b.isNotNull && 'c.isNotNull) - .select('a.lowerCase(), 'b, 'rowtime) + .select('a.lowerCase() as 'a, 'b, 'rowtime) .window(Tumble over 1.hour on 'rowtime as 'hourlyWindow) .groupBy('hourlyWindow, 'a) .select('a, 'hourlyWindow.end as 'hour, 'b.avg as 'avgBillingAmount)