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)
