Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 2172C200B9C for ; Mon, 10 Oct 2016 20:21:52 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 202F0160AE1; Mon, 10 Oct 2016 18:21:52 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 66512160AD1 for ; Mon, 10 Oct 2016 20:21:51 +0200 (CEST) Received: (qmail 26881 invoked by uid 500); 10 Oct 2016 18:21:50 -0000 Mailing-List: contact users-help@asterixdb.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@asterixdb.apache.org Delivered-To: mailing list users@asterixdb.apache.org Received: (qmail 26871 invoked by uid 99); 10 Oct 2016 18:21:50 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 10 Oct 2016 18:21:50 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id D67641A033A for ; Mon, 10 Oct 2016 18:21:49 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.929 X-Spam-Level: * X-Spam-Status: No, score=1.929 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, FREEMAIL_ENVFROM_END_DIGIT=0.25, HTML_MESSAGE=2, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id T4YLT6_YhH_7 for ; Mon, 10 Oct 2016 18:21:47 +0000 (UTC) Received: from mail-it0-f45.google.com (mail-it0-f45.google.com [209.85.214.45]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id B5EF85F471 for ; Mon, 10 Oct 2016 18:21:46 +0000 (UTC) Received: by mail-it0-f45.google.com with SMTP id o19so1178830ito.1 for ; Mon, 10 Oct 2016 11:21:46 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:from:date:message-id:subject:to; bh=N2aBmziJjBJFls8VFMuB+s/d2yj8e1ontRJ7ufjLNXI=; b=OvLk4xvwCK+uGicU7sdjnLN6zrh7YtwnbQv8MXaGhQz5s6pfqMOwZHRkm1khVqyMXk Aq2D0J3G2tbKEY3uHIZ6wBc+sJWLUgH1nDbmfXB+duXELelIjGz8I4W/E42bu80vyvOy PNBb0zNVq1hqnjyeU/rZ307ccik5VyJyjXoPEpo5qQ4fwIT+HnaIP3yx9JT4QCAdtuTO jEPiZGIZxfWO04FpO8Gu6UvVLm4m9HcjvNWhNRDJ0VTXMNw5MP3znZlteAy3/WCX+7Qv z0Vort0W4R+2CBX4lfRJzYNxE2BkcwyaxwErbnpRXzcXuvkXZtR8Xystcjd2C6mdG78U eTJw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:from:date:message-id:subject:to; bh=N2aBmziJjBJFls8VFMuB+s/d2yj8e1ontRJ7ufjLNXI=; b=dOq0huPzl6NSIZE/hTUMp3iJ6DV4mKPGAel6+ZMW4fDr8fyUaUmeQTOXWHslmhBCKn BodLxEy3+zcjiK79GUhxQw5qkkPI9zzHl7dDRB7J2Sc6/QdMwJcsYGTXbrDz9f+5W88k yks1+rnI7S9Su0MM6vflme1nL5r7YFEkGYU/p4ZdnqHL5kYwq6Uc5NArOVkTKVdKMlu2 b3n5u3rLYZBNgGDo+xTcK03qFTnLCIdLfo2cYEExEttD6s+/+OjairSKWjbXmq6uH0Sq 8KmdC7Lye4ke7Tj1QMR1KjotIPiriet5gYWCKpPc0Sn1XyzpiMSJaWJugacuSuV4ltMJ Kw6g== X-Gm-Message-State: AA6/9Rlca4GracX16qq6vADNIMkl8HZIw/uTvH4hONiuBTdYJHIv6xca1TXaIzwuig31/Mq97UbAfBY+6lo3Jg== X-Received: by 10.36.67.65 with SMTP id s62mr2804112itb.106.1476123704075; Mon, 10 Oct 2016 11:21:44 -0700 (PDT) MIME-Version: 1.0 Received: by 10.107.46.144 with HTTP; Mon, 10 Oct 2016 11:21:03 -0700 (PDT) From: mingda li Date: Mon, 10 Oct 2016 11:21:03 -0700 Message-ID: Subject: Let one Operator finished the job before another one begin in Hyracks To: users@asterixdb.apache.org Content-Type: multipart/alternative; boundary=001a1143dbf006d142053e86d59a archived-at: Mon, 10 Oct 2016 18:21:52 -0000 --001a1143dbf006d142053e86d59a Content-Type: text/plain; charset=UTF-8 Hi, Now,I am trying to build a Bloom Filter(BF) before join. The BF is build in each node and sent to one node to combine. I want to set a stop sign there before sending the BF in each node. The stop sign means it can only send the BF after it is build. The class HyracksConnection.waitForCompletion may help this. But I am not sure how to use it. Should I build two jobs: hcc.waitForCompletion(jobBuildBF); jobidSendBF=hcc.startJob(); ? Has anyone ever used the HyracksConnection.waitForCompletion? Thanks, Mingda --001a1143dbf006d142053e86d59a Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi,

Now,I am trying to build a Bloom Fi= lter(BF) before join. The BF is build in each node and sent to one node to = combine. I want to set a stop sign there before sending the BF in each node= . The stop sign means it can only send the BF after it is build.=C2=A0
The class HyracksConnection.waitForCompletion may help this. But I am= not sure how to use it.
Should I build two jobs: hcc.waitForComp= letion(jobBuildBF); jobidSendBF=3Dhcc.startJob();=C2=A0?
Has anyo= ne ever used the=C2=A0HyracksConnection.waitForCompletion?

Thanks,
Mingda

--001a1143dbf006d142053e86d59a--