From 1df3400e90bb9f5816e92254b03fac674ef27076 Mon Sep 17 00:00:00 2001 From: hequn8128 Date: Tue, 15 Jan 2019 18:31:57 +0800 Subject: [PATCH 1/2] [FLINK-11331][table][docs] Fix errors in tableApi.md and functions.md --- docs/dev/table/functions.md | 48 ++++++++++++++++++++++++++++++++++++- docs/dev/table/tableApi.md | 4 ++-- 2 files changed, 49 insertions(+), 3 deletions(-) diff --git a/docs/dev/table/functions.md b/docs/dev/table/functions.md index 682f519eb3ce6..2c8ff520c7d8c 100644 --- a/docs/dev/table/functions.md +++ b/docs/dev/table/functions.md @@ -3573,7 +3573,17 @@ 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.

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

Creates an interval of milliseconds for NUMERIC weeks.

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

Creates an interval of months for NUMERIC quarters.

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

Creates an interval of milliseconds for NUMERIC weeks.

+ + + {% 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) From f4494fafa60204d65fc015896433569a1713949b Mon Sep 17 00:00:00 2001 From: hequn8128 Date: Wed, 16 Jan 2019 14:34:06 +0800 Subject: [PATCH 2/2] add examples for udfs --- docs/dev/table/functions.md | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/docs/dev/table/functions.md b/docs/dev/table/functions.md index 2c8ff520c7d8c..f41139d14957c 100644 --- a/docs/dev/table/functions.md +++ b/docs/dev/table/functions.md @@ -3582,6 +3582,7 @@ NUMERIC.quarters

Creates an interval of months for NUMERIC quarters.

+

E.g., 2.quarters returns 6.

@@ -3605,6 +3606,7 @@ NUMERIC.weeks

Creates an interval of milliseconds for NUMERIC weeks.

+

E.g., 2.weeks returns 1209600000.

@@ -3862,6 +3864,7 @@ NUMERIC.quarters

Creates an interval of months for NUMERIC quarters.

+

E.g., 2.quarters returns 6.

@@ -3886,6 +3889,7 @@ NUMERIC.weeks

Creates an interval of milliseconds for NUMERIC weeks.

+

E.g., 2.weeks returns 1209600000.