Github user fhueske commented on a diff in the pull request:

    https://github.com/apache/flink/pull/4842#discussion_r145253981
  
    --- Diff: docs/dev/table/tableApi.md ---
    @@ -583,7 +584,8 @@ tEnv.registerFunction("split", split);
     // join
     Table orders = tableEnv.scan("Orders");
     Table result = orders
    -    .leftOuterJoin(new Table(tEnv, "split(c)").as("s", "t", "v")))
    +    .leftOuterJoin(new Table(tEnv, "split(c)").as("s", "t", "v"))
    +    .where("a > 5")
    --- End diff --
    
    I would not add this. It's a local predicate on the outer table and not 
related to the table function join.


---

Reply via email to