[jira] [Created] (FLINK-5511) Add support for outer joins with local predicates

["lincoln.lee (JIRA)" <ji...@apache.org>]

lincoln.lee created FLINK-5511:
----------------------------------

             Summary: Add support for outer joins with local predicates
                 Key: FLINK-5511
                 URL: https://issues.apache.org/jira/browse/FLINK-5511
             Project: Flink
          Issue Type: Improvement
          Components: Table API & SQL
            Reporter: lincoln.lee
            Assignee: lincoln.lee
            Priority: Minor


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.” 
{code:title=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) 
} 
{code} 
This jira aims to supported this kind of local predicates in outer joins. 

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



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)