|
|
when write this code value keep in linked list and return this value No output code
new FilterFunction<Customer>() {
@Override
public boolean filter(Customer c) {
return c.getField(4).equals(values.get(0).toString()) && c.getField(2).equals(values.get(1).toString()) ;
}
});
but when write the coding result coding = (2,Customer#000000002,XSTf4&&NCwDVaWNe6tEgvwfmRchLXak,121.65,AUTOMOBILE)
new FilterFunction<Customer>() {
@Override
public boolean filter(Customer c) {
return c.getField(4).equals("AUTOMOBILE") && c.getField(2).equals("XSTf4&&NCwDVaWNe6tEgvwfmRchLXak") ;
}
});
coding
public static LinkedList values=new LinkedList<String>();
public static void main(String[] args) throws Exception {
values.add("AUTOMOBILE");
values.add("XSTf4&&NCwDVaWNe6tEgvwfmRchLXak");
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
DataSet<Customer> customers = getCustomerDataSet(env);
customers = customers.filter(
new FilterFunction<Customer>() {
@Override
public boolean filter(Customer c) {
return c.getField(4).equals(values.get(0).toString()) && c.getField(2).equals(values.get(1).toString()) ;
}
});
System.out.println(customers.print());
customers.writeAsCsv("/home/hadoop/Desktop/Dataset/output.csv", "\n", "|");
env.execute();
}
public static class Customer extends Tuple5<Long,String,String,String,String> {
}
private static DataSet<Customer> getCustomerDataSet(ExecutionEnvironment env) {
return env.readCsvFile("/home/hadoop/Desktop/Dataset/customer.csv")
.fieldDelimiter('|')
.includeFields("11100110").ignoreFirstLine()
.tupleType(Customer.class);
}\
|
Locked
