This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch release-1.8
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.8 by this push:
new dd89cc7 [hotfix][docs] Fix missing joinLateral
dd89cc7 is described below
commit dd89cc71bd0ba4d1c04916528ac74f975359bdb9
Author: sunjincheng121 <[email protected]>
AuthorDate: Thu Feb 28 14:15:04 2019 +0100
[hotfix][docs] Fix missing joinLateral
---
docs/dev/table/tableApi.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/dev/table/tableApi.md b/docs/dev/table/tableApi.md
index 3f1992d..9fdbf47 100644
--- a/docs/dev/table/tableApi.md
+++ b/docs/dev/table/tableApi.md
@@ -832,7 +832,7 @@ val rates =
ratesHistory.createTemporalTableFunction('r_proctime, 'r_currency)
// join with "Orders" based on the time attribute and key
val orders = tableEnv.scan("Orders")
val result = orders
- .join(rates('o_rowtime), 'r_currency === 'o_currency)
+ .joinLateral(rates('o_rowtime), 'r_currency === 'o_currency)
{% endhighlight %}
<p>For more information please check the more detailed <a
href="streaming/temporal_tables.html">temporal tables concept
description</a>.</p>
</td>
