flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "lincoln.lee (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-5511) Add support for outer joins with local predicates
Date Mon, 16 Jan 2017 14:27:26 GMT
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)

Mime
View raw message