Return-Path: 
 <user-return-2181-apmail-flink-user-archive=flink.apache.org@flink.apache.org>
X-Original-To: apmail-flink-user-archive@minotaur.apache.org
Delivered-To: apmail-flink-user-archive@minotaur.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id A99A918B13
	for <apmail-flink-user-archive@minotaur.apache.org>;
 Tue, 21 Jul 2015 12:54:38 +0000 (UTC)
Received: (qmail 80998 invoked by uid 500); 21 Jul 2015 12:54:32 -0000
Delivered-To: apmail-flink-user-archive@flink.apache.org
Received: (qmail 80923 invoked by uid 500); 21 Jul 2015 12:54:32 -0000
Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:user-help@flink.apache.org>
List-Unsubscribe: <mailto:user-unsubscribe@flink.apache.org>
List-Post: <mailto:user@flink.apache.org>
List-Id: <user.flink.apache.org>
Reply-To: user@flink.apache.org
Delivered-To: mailing list user@flink.apache.org
Received: (qmail 80913 invoked by uid 99); 21 Jul 2015 12:54:32 -0000
Received: from Unknown (HELO spamd1-us-west.apache.org) (209.188.14.142)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 21 Jul 2015 12:54:32 +0000
Received: from localhost (localhost [127.0.0.1])
	by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org)
 with ESMTP id CEFF5D665C
	for <user@flink.apache.org>; Tue, 21 Jul 2015 12:54:31 +0000 (UTC)
X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org
X-Spam-Flag: NO
X-Spam-Score: 4.439
X-Spam-Level: ****
X-Spam-Status: No, score=4.439 tagged_above=-999 required=6.31
	tests=[DKIM_ADSP_CUSTOM_MED=0.001, FORGED_YAHOO_RCVD=1.022,
	FREEMAIL_ENVFROM_END_DIGIT=0.25, NML_ADSP_CUSTOM_MED=1.2,
	SPF_NEUTRAL=0.652, URIBL_BLOCKED=0.001, URI_HEX=1.313]
	autolearn=disabled
Received: from mx1-us-west.apache.org ([10.40.0.8])
	by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new,
 port 10024)
	with ESMTP id FiAExirqi894 for <user@flink.apache.org>;
	Tue, 21 Jul 2015 12:54:24 +0000 (UTC)
Received: from mwork.nabble.com (mwork.nabble.com [162.253.133.43])
	by mx1-us-west.apache.org (ASF Mail Server at mx1-us-west.apache.org) with
 ESMTP id 6DA1B24961
	for <user@flink.apache.org>; Tue, 21 Jul 2015 12:54:24 +0000 (UTC)
Received: from mjoe.nabble.com (unknown [162.253.133.57])
	by mwork.nabble.com (Postfix) with ESMTP id 6606B240E3EA
	for <user@flink.apache.org>; Tue, 21 Jul 2015 05:54:28 -0700 (PDT)
Date: Tue, 21 Jul 2015 05:53:36 -0700 (PDT)
From: hagersaleh <loveallah1987@yahoo.com>
To: user@flink.apache.org
Message-ID: <1437483216674-2205.post@n4.nabble.com>
Subject: when write this code display error  no interface expected here
 public static class MyCoGrouper extends CoGroupFunction
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

when write this code display error
 no interface expected here public static class MyCoGrouper extends
CoGroupFunction<Customer,Orders,Result> {

ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

        DataSet<Customer> customers = getCustomerDataSet(env,mask,l,map);

        DataSet<Orders> orders= getOrdersDataSet(env,maskorder,l1,maporder);

        DataSet<Result> result =
customers.coGroup(orders).where(0).equalTo(1).with
            (new CoGroupFunction<Customer,Orders,Result>() {

        @Override
        public void coGroup(Iterator<Customer> leftElements,
                            Iterator<Orders> rightElements,
                           Collector<Result> 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.