You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by GitBox <gi...@apache.org> on 2019/01/16 06:54:27 UTC
[flink] Diff for: [GitHub] asfgit closed pull request #7494:
[FLINK-11331][table][docs] Fix errors in tableApi.md and functions.md
diff --git a/docs/dev/table/functions.md b/docs/dev/table/functions.md
index 682f519eb3c..f41139d1495 100644
--- a/docs/dev/table/functions.md
+++ b/docs/dev/table/functions.md
@@ -3573,7 +3573,18 @@ NUMERIC.years
<p>Creates an interval of months for <i>NUMERIC</i> years.</p>
</td>
</tr>
-
+ <tr>
+ <td>
+ {% highlight java %}
+NUMERIC.quarter
+NUMERIC.quarters
+{% endhighlight %}
+ </td>
+ <td>
+ <p>Creates an interval of months for <i>NUMERIC</i> quarters.</p>
+ <p>E.g., <code>2.quarters</code> returns 6.</p>
+ </td>
+ </tr>
<tr>
<td>
{% highlight java %}
@@ -3586,6 +3597,19 @@ NUMERIC.months
</td>
</tr>
+ <tr>
+ <td>
+ {% highlight java %}
+NUMERIC.week
+NUMERIC.weeks
+{% endhighlight %}
+ </td>
+ <td>
+ <p>Creates an interval of milliseconds for <i>NUMERIC</i> weeks.</p>
+ <p>E.g., <code>2.weeks</code> returns 1209600000.</p>
+ </td>
+ </tr>
+
<tr>
<td>
{% highlight java %}
@@ -3831,6 +3855,19 @@ NUMERIC.years
</td>
</tr>
+ <tr>
+ <td>
+ {% highlight scala %}
+NUMERIC.quarter
+NUMERIC.quarters
+{% endhighlight %}
+ </td>
+ <td>
+ <p>Creates an interval of months for <i>NUMERIC</i> quarters.</p>
+ <p>E.g., <code>2.quarters</code> returns 6.</p>
+ </td>
+ </tr>
+
<tr>
<td>
{% highlight scala %}
@@ -3843,6 +3880,19 @@ NUMERIC.months
</td>
</tr>
+ <tr>
+ <td>
+ {% highlight scala %}
+NUMERIC.week
+NUMERIC.weeks
+{% endhighlight %}
+ </td>
+ <td>
+ <p>Creates an interval of milliseconds for <i>NUMERIC</i> weeks.</p>
+ <p>E.g., <code>2.weeks</code> returns 1209600000.</p>
+ </td>
+ </tr>
+
<tr>
<td>
{% highlight scala %}
diff --git a/docs/dev/table/tableApi.md b/docs/dev/table/tableApi.md
index e44df24ad5e..d44eebddf53 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)
With regards,
Apache Git Services