[FLINK-5511] Add support for outer joins with local predicates

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Duplicate
• Component/s: Table SQL / API
• Assignee: lincoln lee
• Reporter: lincoln lee
• Created: 16/Jan/17 14:26
• Updated: 12/Dec/18 07:44
• Resolved: 21/Feb/17 10:19

Description

currently the test case in flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/table/JoinITCase.scala
will throw a ValidationException indicating: “Invalid non-join predicate 'b < 3. For non-join predicates use Table#where.”

JoinITCase.scala

 
@Test(expected = classOf[ValidationException]) 
def testNoJoinCondition(): Unit = { 
     … 
     val ds1 = CollectionDataSets.get3TupleDataSet(env).toTable(tEnv, 'a, 'b, 'c) 
     val ds2 = CollectionDataSets.get5TupleDataSet(env).toTable(tEnv, 'd, 'e, 'f, 'g, 'h) 

     val joinT = ds2.leftOuterJoin(ds1, 'b === 'd && 'b < 3).select('c, 'g) 
} 

This jira aims to supported this kind of local predicates in outer joins.

More detailed description: http://goo.gl/gK6vP3

Issue Links

• duplicates: FLINK-5498 Add support for left/right outer joins with non-equality predicates (and 1+ equality predicates)