Re: when write this code display error no interface expected here public static class MyCoGrouper extends CoGroupFunction

[hagersaleh]

please help



--
View this message in context: 
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/when-write-this-code-display-error-no-interface-expected-here-public-static-class-MyCoGrouper-extendn-tp2205p2219.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at 
Nabble.com.

when write this code display error no interface expected here public static class MyCoGrouper extends CoGroupFunction

[hagersaleh]

when write this code display error
 no interface expected here public static class MyCoGrouper extends
CoGroupFunctionCustomer,Orders,Result {

ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

DataSetCustomer customers = getCustomerDataSet(env,mask,l,map);

DataSetOrders orders= getOrdersDataSet(env,maskorder,l1,maporder);

DataSetResult result =
customers.coGroup(orders).where(0).equalTo(1).with
(new CoGroupFunctionCustomer,Orders,Result() {

@Override
public void coGroup(IteratorCustomer leftElements,
IteratorOrders rightElements,
   CollectorResult out) throws Exception {

 if(rightElements.hasNext()) {
   while(leftElements.hasNext()) {

out.collect(new
Result(leftElements.next().f0,leftElements.next().f1,rightElements.next().f0
   ,rightElements.next().f1,rightElements.next().f2));

}
}

}
}); 



--
View this message in context: 
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/when-write-this-code-display-error-no-interface-expected-here-public-static-class-MyCoGrouper-extendn-tp2205.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at 
Nabble.com.