[jira] [Created] (FLINK-4541) Support for SQL NOT IN operator

["Timo Walther (JIRA)" <ji...@apache.org>]

Timo Walther created FLINK-4541:
-----------------------------------

             Summary: Support for SQL NOT IN operator
                 Key: FLINK-4541
                 URL: https://issues.apache.org/jira/browse/FLINK-4541
             Project: Flink
          Issue Type: Improvement
          Components: Table API & SQL
            Reporter: Timo Walther


This should work:

{code}
def main(args: Array[String]): Unit = {

    // set up execution environment
    val env = ExecutionEnvironment.getExecutionEnvironment
    val tEnv = TableEnvironment.getTableEnvironment(env)

    val input = env.fromElements(WC("hello", 1), WC("hello", 1), WC("ciao", 1))

    // register the DataSet as table "WordCount"
    tEnv.registerDataSet("WordCount", input, 'word, 'frequency)

    tEnv.registerTable("WordCount2", tEnv.fromDataSet(input, 'word, 'frequency).select('word).filter('word !== "hello"))

    // run a SQL query on the Table and retrieve the result as a new Table
    val table = tEnv.sql("SELECT word, SUM(frequency) FROM WordCount WHERE word NOT IN (SELECT word FROM WordCount2) GROUP BY word")

    table.toDataSet[WC].print()
  }
{code}



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