.C_MKTSEGMENT = c2.C_MKTSEGMENT
AND c2.C_ADDRESS="MG9kdTD2WBHm"
-Matthias
On 05/05/2015 06:01 PM, hager sallah wrote:
> 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")
>
>
>
>
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")
how can handle left outer join for any two dataset this dataset inlcude any
filed number
example on two dataset data set one
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
DataSet>
customer=env.readCsvFile("/home/hadoop/Desktop/Dataset/customer.csv")
.fieldDelimiter('
I use linkedlist to pass value in filter function in this coding not resulting
from code but when pass value direct to filter function th result is
(2,Customer#2,XSTf4&&NCwDVaWNe6tEgvwfmRchLXak,121.65,AUTOMOBILE)problem
in this line i pass value from linkedlist
c.getField(4).equals(val
I want write program flink on any databaseuser input filed and type of filed
and when read database want generate automatic function dataset
any example in flink i know database and write function to handles
thisexamplefinal ExecutionEnvironment env =
ExecutionEnvironment.getExecutionEnvironme
