This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 980ff05  [hotfix][docs] Fix missing joinLateral
980ff05 is described below

commit 980ff0511f1dcf63cf08a4f8b88121586121deec
Author: sunjincheng121 <sunjincheng...@gmail.com>
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>

Reply via email to