You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by hagersaleh <lo...@yahoo.com> on 2015/04/26 14:47:07 UTC

how can handle left outer join for any two dataset

how can handle left outer join for any two dataset this dataset inlcude any
filed number
example

data set one
 ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
DataSet<Tuple4&lt;Integer, String, String,String>>
customer=env.readCsvFile("/home/hadoop/Desktop/Dataset/customer.csv")
.fieldDelimiter('|')
.includeFields("11110000").ignoreFirstLine()
.types(Integer.class,String.class,String.class,String.class);

dataset two

 ExecutionEnvironment orders =
ExecutionEnvironment.getExecutionEnvironment();
DataSet<Tuple3&lt;Integer, String, String>
customer=env.readCsvFile("/home/hadoop/Desktop/Dataset/order.csv")
.fieldDelimiter('|')
.includeFields("11110000").ignoreFirstLine()
.types(Integer.class,String.class,String.classs);



--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/how-can-handle-left-outer-join-for-any-two-dataset-tp1130.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.