Re: how can implemented subquery in flink

2015-05-05 Thread hager sallah
>From Customers AS c1, Customers AS c2 this is two dataset how can use filter function implemented this On Tuesday, May 5, 2015 9:30 AM, Matthias J. Sax wrote: If the sub-query is not correlated, you can (always) transform it into a simple join query. However, the query you show is

Re: how can implemented subquery in flink

2015-05-05 Thread Matthias J. Sax
If the sub-query is not correlated, you can (always) transform it into a simple join query. However, the query you show is no valid SQL... Did you mean: SELECT C_CUSTKEY,C_NAME FROM Customers WHERE C_MKTSEGMENT = (SELECT C_MKTSEGMENT FROM Customers WHERE C_ADDRESS="MG9kdTD2WBHm") In this case,

how can implemented subquery in flink

2015-05-05 Thread hager sallah
how can implemented subquery in flinkexample SELECT C_CUSTKEY,C_NAME FROM Customers where C_MKTSEGMENT=(select C_CUSTKEY,C_MKTSEGMENT from Customers where C_ADDRESS="MG9kdTD2WBHm")

[jira] [Created] (FLINK-1970) how can implemented subquery in flink

2015-05-04 Thread hagersaleh (JIRA)
hagersaleh created FLINK-1970: - Summary: how can implemented subquery in flink Key: FLINK-1970 URL: https://issues.apache.org/jira/browse/FLINK-1970 Project: Flink Issue Type: Bug