want return all row include all value in valuesfromsubquery this code just
return row include frist value BUILDING
public static ArrayList<String> valuesfromsubquery = new
ArrayList<String>();
valuesfromsubquery.add("BUILDING");
valuesfromsubquery.add("MACHINERY");
valuesfromsubquery.add("AUTOMOBILE");
DataSet<Customer3>
customers=env.readCsvFile("/home/hadoop/Desktop/Dataset/customer.csv")
.fieldDelimiter('|')
.includeFields(mask).ignoreFirstLine()
.tupleType(Customer3.class);
customers = customers.filter(new
FilterFunction<Customer3>()
{
@Override
public boolean filter(Customer3 c) {
for(int i=0;i<valuesfromsubquery.size();i++)
return
c.getField(index1).toString().equals(valuesfromsubquery.get(i));
return true;
}
});
customers.print();
customers.writeAsCsv("/home/hadoop/Desktop/Dataset/out2.csv", "\n",
"|",WriteMode.OVERWRITE);
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/how-can-rturn-all-row-in-dataset-include-mult-value-example-tp1289.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.