You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2018/01/09 12:37:07 UTC
[3/3] flink git commit: [hotfix] [docs] Update documentation about
joins
[hotfix] [docs] Update documentation about joins
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fddedda7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fddedda7
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fddedda7
Branch: refs/heads/master
Commit: fddedda78ad03f1141f3e32f0e0f39c2e045df0e
Parents: 222e694
Author: twalthr <tw...@apache.org>
Authored: Tue Jan 9 12:28:47 2018 +0100
Committer: twalthr <tw...@apache.org>
Committed: Tue Jan 9 12:28:47 2018 +0100
----------------------------------------------------------------------
docs/dev/table/sql.md | 24 +++++++++++++++++++++---
docs/dev/table/tableApi.md | 2 ++
2 files changed, 23 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/fddedda7/docs/dev/table/sql.md
----------------------------------------------------------------------
diff --git a/docs/dev/table/sql.md b/docs/dev/table/sql.md
index d9a4ce7..7dfce78 100644
--- a/docs/dev/table/sql.md
+++ b/docs/dev/table/sql.md
@@ -376,9 +376,10 @@ GROUP BY users
</tr>
</thead>
<tbody>
- <tr>
- <td><strong>Inner Equi-join / Outer Equi-join</strong><br>
+ <tr>
+ <td><strong>Inner Equi-join</strong><br>
<span class="label label-primary">Batch</span>
+ <span class="label label-primary">Streaming</span>
</td>
<td>
<p>Currently, only equi-joins are supported, i.e., joins that have at least one conjunctive condition with an equality predicate. Arbitrary cross or theta joins are not supported.</p>
@@ -386,9 +387,26 @@ GROUP BY users
{% highlight sql %}
SELECT *
FROM Orders INNER JOIN Product ON Orders.productId = Product.id
-
+{% endhighlight %}
+<p><b>Note:</b> For streaming queries the required state to compute the query result might grow infinitely depending on the number of distinct input rows. Please provide a query configuration with valid retention interval to prevent excessive state size. See <a href="streaming.html">Streaming Concepts</a> for details.</p>
+ </td>
+ </tr>
+ <tr>
+ <td><strong>Outer Equi-join</strong><br>
+ <span class="label label-primary">Batch</span>
+ </td>
+ <td>
+ <p>Currently, only equi-joins are supported, i.e., joins that have at least one conjunctive condition with an equality predicate. Arbitrary cross or theta joins are not supported.</p>
+ <p><b>Note:</b> The order of joins is not optimized. Tables are joined in the order in which they are specified in the FROM clause. Make sure to specify tables in an order that does not yield a cross join (Cartesian product) which are not supported and would cause a query to fail.</p>
+{% highlight sql %}
SELECT *
FROM Orders LEFT JOIN Product ON Orders.productId = Product.id
+
+SELECT *
+FROM Orders RIGHT JOIN Product ON Orders.productId = Product.id
+
+SELECT *
+FROM Orders FULL OUTER JOIN Product ON Orders.productId = Product.id
{% endhighlight %}
</td>
</tr>
http://git-wip-us.apache.org/repos/asf/flink/blob/fddedda7/docs/dev/table/tableApi.md
----------------------------------------------------------------------
diff --git a/docs/dev/table/tableApi.md b/docs/dev/table/tableApi.md
index 3b31325..7dedcc4 100644
--- a/docs/dev/table/tableApi.md
+++ b/docs/dev/table/tableApi.md
@@ -491,6 +491,7 @@ val result = orders.distinct()
<td>
<strong>Inner Join</strong><br>
<span class="label label-primary">Batch</span>
+ <span class="label label-primary">Streaming</span>
</td>
<td>
<p>Similar to a SQL JOIN clause. Joins two tables. Both tables must have distinct field names and at least one equality join predicate must be defined through join operator or using a where or filter operator.</p>
@@ -499,6 +500,7 @@ Table left = tableEnv.fromDataSet(ds1, "a, b, c");
Table right = tableEnv.fromDataSet(ds2, "d, e, f");
Table result = left.join(right).where("a = d").select("a, b, e");
{% endhighlight %}
+<p><b>Note:</b> For streaming queries the required state to compute the query result might grow infinitely depending on the number of distinct input rows. Please provide a query configuration with valid retention interval to prevent excessive state size. See <a href="streaming.html">Streaming Concepts</a> for details.</p>
</td>
</tr>