From dev-return-13165-apmail-ignite-dev-archive=ignite.apache.org@ignite.apache.org Mon May 30 16:14:22 2016 Return-Path: X-Original-To: apmail-ignite-dev-archive@minotaur.apache.org Delivered-To: apmail-ignite-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id D98E219D17 for ; Mon, 30 May 2016 16:14:22 +0000 (UTC) Received: (qmail 12302 invoked by uid 500); 30 May 2016 16:14:22 -0000 Delivered-To: apmail-ignite-dev-archive@ignite.apache.org Received: (qmail 12256 invoked by uid 500); 30 May 2016 16:14:22 -0000 Mailing-List: contact dev-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.apache.org Delivered-To: mailing list dev@ignite.apache.org Received: (qmail 12244 invoked by uid 99); 30 May 2016 16:14:22 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 30 May 2016 16:14:22 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id A3A11C0EAF for ; Mon, 30 May 2016 16:14:21 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.298 X-Spam-Level: * X-Spam-Status: No, score=1.298 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H2=-0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gridgain-com.20150623.gappssmtp.com Received: from mx2-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id HsZTG0iuxI59 for ; Mon, 30 May 2016 16:14:19 +0000 (UTC) Received: from mail-io0-f177.google.com (mail-io0-f177.google.com [209.85.223.177]) by mx2-lw-eu.apache.org (ASF Mail Server at mx2-lw-eu.apache.org) with ESMTPS id 830AC5F36F for ; Mon, 30 May 2016 16:14:18 +0000 (UTC) Received: by mail-io0-f177.google.com with SMTP id p64so68977233ioi.2 for ; Mon, 30 May 2016 09:14:18 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gridgain-com.20150623.gappssmtp.com; s=20150623; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=x22OLajuC9NgNkWIn7vEIvLg6LDiiRud82C+YyWJ7Yk=; b=FuLd22XSarjeO9jMw2uWwuHSgvdTqWdxeTZWCXFp1Y0NDyemFTtnc6e8JMibb9cMQI 6ysitsgGoeGvLjT4cMiuoHJYJqOx4psFqUnzmFIYOB7tW6WLIzjiVKbdRWd7FFDGEvYy yfxi4A0LE5iw/UiDnn6ozyDk9poWIr7qd2G0PBy3za3ZFxzawLnbEyZHoEJa4q5k5FiZ +exs89H73JxoZyTjBLHEMjqvUouWJhcWMkXBg/9oeEMLJ9qQlHDUYPORN9IkNcRkp6Qk bRHdRcAGvV8u0Sg192R9/SEhkOoXzwLiMxeTXlcf9PNLg6RBDZ4EYPNN6NS+cbZilAge XApA== 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=x22OLajuC9NgNkWIn7vEIvLg6LDiiRud82C+YyWJ7Yk=; b=EpuzBlSdWUpL2KXqckSQ2yhEAVSsEaFLaNB0oOdhrKSFvasm1opiOQSknmqnazfvUm FZb71rVMPKJzqDMwFYSThLCegabEXtaGRro8JVH7JIcXZPdAQBgkcFpjHwOy40Bo2rAM sxKeOOvaX5zAvLTtnW/tJGIMmNbxl6qqj1OHojXevJVB268fZR1yOGy7Sa2GNmaQTQOw Fd07SS9Kc0DpszKI/mCNM97n7s9LzFKjvj7lkoAB2VwPzUh6PgVdSVn8lEN6PzfHjqP/ n2B6QNsKNrP4lIc8A+FFA1XPBew+UuJnnu9j+8ZFhDFz/Sy/OtwmWSf5rPoXB4EndiI7 uGhw== X-Gm-Message-State: ALyK8tIAgZIXz3LVlnhu3ZuiWELCIptt9IJK1m1I8JAPT3DVaCVzmU6KkhEh6DrEgR9i7gHjnw5eX6F/rzo8uZh8 X-Received: by 10.107.34.213 with SMTP id i204mr21426804ioi.39.1464624851208; Mon, 30 May 2016 09:14:11 -0700 (PDT) MIME-Version: 1.0 Received: by 10.36.248.199 with HTTP; Mon, 30 May 2016 09:13:41 -0700 (PDT) In-Reply-To: References: From: Pavel Tupitsyn Date: Mon, 30 May 2016 19:13:41 +0300 Message-ID: Subject: Re: IgniteCache.invoke on ALL keys To: dev@ignite.apache.org Content-Type: multipart/alternative; boundary=001a113f5962fc67aa0534118b6c --001a113f5962fc67aa0534118b6c Content-Type: text/plain; charset=UTF-8 Dmitriy, as I understand, there is no reliable way to do that if rebalancing happens. On Mon, May 30, 2016 at 6:50 PM, Dmitriy Setrakyan wrote: > I think we do support this use case. Why not send a computation to a server > and then perform the iteration through the cache entries locally on that > server? > > On Mon, May 30, 2016 at 4:44 AM, Pavel Tupitsyn > wrote: > > > Igniters, > > > > Looks like we do not have an efficient way to perform an action on EVERY > > cache entry. > > > > Let's say I want to remove all entries that match a predicate. > > My only option is to retrieve these entries via Scan or SQL query, and > then > > call removeAll. > > This involves a lot of unnecessary network trips (send keys to caller > node, > > send them back to primary nodes). > > > > Would it be possible to implement a method like > > void IgniteCache.invokeAll(entryProcessor) > > that invokes the processor on all entries and does not return anything? > > There could be more overloads that return results or only return results > > for changed entries. > > > > Thoughts? > > > > Pavel. > > > --001a113f5962fc67aa0534118b6c--