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 7FE03200B9C for ; Mon, 10 Oct 2016 21:55:40 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 7E94D160AE1; Mon, 10 Oct 2016 19:55:40 +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 C4FC3160AD1 for ; Mon, 10 Oct 2016 21:55:39 +0200 (CEST) Received: (qmail 17692 invoked by uid 500); 10 Oct 2016 19:55:39 -0000 Mailing-List: contact dev-help@asterixdb.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@asterixdb.apache.org Delivered-To: mailing list dev@asterixdb.apache.org Received: (qmail 17676 invoked by uid 99); 10 Oct 2016 19:55:38 -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 19:55:38 +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 445741A062B for ; Mon, 10 Oct 2016 19:55:38 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.398 X-Spam-Level: ** X-Spam-Status: No, score=2.398 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.001, 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 FZJvm3Mc9EBS for ; Mon, 10 Oct 2016 19:55:36 +0000 (UTC) Received: from mail-vk0-f43.google.com (mail-vk0-f43.google.com [209.85.213.43]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id A81C35F471 for ; Mon, 10 Oct 2016 19:55:35 +0000 (UTC) Received: by mail-vk0-f43.google.com with SMTP id z126so36897vkd.0 for ; Mon, 10 Oct 2016 12:55:35 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=mCGlvTGVrYWBIVsNf9mrlp2fJll4KdrzRn5Ajdn2DeA=; b=McM/UbeX2yJIMq+Rf6+xHniO6BokADi9151ExDp9HyN3+ptecAO8cfLU5XJsjEXqbb SJWlt0OyH61ePq4g33Qi+XdvxaYrPnza00rXpXK+sMQErL0G4XCf6euhsmaykHyoHv6D X32tOJvAakOgd1tlMoRUWwddsQpWShbkVqdQjGMKYVFZzh4x+s3A27xYAGCquC32ALVL EsRBzkGAfLTxV/VwoWJmqUHG7jlTTrO9tg2+QbnnWZzR5ix9/wTaTsyl383WY7Xzul64 lOCe447ngfW88EbIJ+87p2iJQ2Y82SLgQrsSQtj04+OmYhVqicII3VLqjhaIhfDloqS8 vIhg== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=mCGlvTGVrYWBIVsNf9mrlp2fJll4KdrzRn5Ajdn2DeA=; b=DvqC18po1kUjKJ5169NazJNxVEINb8TwRxVdE72sB1/C+IVg6KoOrHoqX1hG27gWL/ IHP3rJ+h5Y90FM8r23z5Ij5uMqUL7zPHUWZO+xzRAJyTaZHtT36chhL810l9mb0bXDpz llLd87i/e/+nIkKonwRLF3yDjRm9q7ah+zA5W27l+LSQBLbJ4Z0kCncDr7Ux6IDDjQKl wcNmyCfy5wQxiyl3ZtXJBldWWOJpxqcdLRuq9wc0phuG0+c//79SvMvtf46gnZppcQ99 RVWR5QAxbLhRCq80OLPN/hrm7//1CoGQ5fLcP3PIC/1Mw6/yjSe1qF0w+JrYJs7oXohq 2v7g== X-Gm-Message-State: AA6/9RnaO6tHb5czsODwUMDCZ+CCeKVYoA/BmyPft3VD6oQHu0Nw7tu7l/5az7UvFM5mCiARmM5Nnf/DEvZQzA== X-Received: by 10.31.233.6 with SMTP id g6mr9946666vkh.148.1476129334486; Mon, 10 Oct 2016 12:55:34 -0700 (PDT) MIME-Version: 1.0 Received: by 10.159.37.101 with HTTP; Mon, 10 Oct 2016 12:55:04 -0700 (PDT) In-Reply-To: References: From: Taewoo Kim Date: Mon, 10 Oct 2016 12:55:04 -0700 Message-ID: Subject: Fwd: Let one Operator finished the job before another one begin in Hyracks To: dev@asterixdb.apache.org Content-Type: multipart/alternative; boundary=94eb2c094bec9fed2c053e8824aa archived-at: Mon, 10 Oct 2016 19:55:40 -0000 --94eb2c094bec9fed2c053e8824aa Content-Type: text/plain; charset=UTF-8 Forwarded to dev. Best, Taewoo ---------- Forwarded message ---------- From: mingda li Date: Mon, Oct 10, 2016 at 11:21 AM Subject: Let one Operator finished the job before another one begin in Hyracks To: users@asterixdb.apache.org 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 --94eb2c094bec9fed2c053e8824aa--