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 66E792009E8 for ; Mon, 30 May 2016 13:45:03 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 658D0160A19; Mon, 30 May 2016 11:45:03 +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 AEBDA160A16 for ; Mon, 30 May 2016 13:45:02 +0200 (CEST) Received: (qmail 65660 invoked by uid 500); 30 May 2016 11:45:01 -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 65647 invoked by uid 99); 30 May 2016 11:45:01 -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 11:45:01 +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 DD42EC0D9E for ; Mon, 30 May 2016 11:45:00 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.279 X-Spam-Level: * X-Spam-Status: No, score=1.279 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_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, 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 I5TIQOPQqdsa for ; Mon, 30 May 2016 11:44:59 +0000 (UTC) Received: from mail-oi0-f42.google.com (mail-oi0-f42.google.com [209.85.218.42]) by mx2-lw-eu.apache.org (ASF Mail Server at mx2-lw-eu.apache.org) with ESMTPS id 68A005F3A0 for ; Mon, 30 May 2016 11:44:59 +0000 (UTC) Received: by mail-oi0-f42.google.com with SMTP id w184so258559989oiw.2 for ; Mon, 30 May 2016 04:44:59 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gridgain-com.20150623.gappssmtp.com; s=20150623; h=mime-version:from:date:message-id:subject:to; bh=76FES/9GJiNiv8HMZlN5z1rg1ZAsCSJQclsHZ9sf6BQ=; b=GhVUKFmFelKNqp8UK80dQYHdni0os4D45aoeIEvjcahK2hmi+ebsw/934goYRhjA1d 50n0pK94qg+bpsMbEP6E45jIfQL0q/sLhB4gldBVxD8UuOf0aWEzD2nxXHGw+UnHupjj 3eW8/b+WBFgrOYGqWgFF6/M8lkOJ4GUZjcDHS1hLciVCQ8++7c1JB2qrfJlnn3FhlLwl eJAYTfMh6CU4URHZqL6MyNvCWSTgSvy8NNnMegh5KMk10o2M8mANXCKUmteXVnuzyiZn ERITFQGKZAWUZc7YuiGm/UUSUMH5RGDVD9tpE5f98HbgfeQyt4KPsphld4L1wOvPKvyJ xpVA== 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=76FES/9GJiNiv8HMZlN5z1rg1ZAsCSJQclsHZ9sf6BQ=; b=HM7BMR4wCXSUcuXS8cq4hZj8S0gGqCl1pNW6+nguccQnpaYXc8JOyfYrG5qN9I4xa6 3SgK0VpBCvkrYfTPIWXJ63EGbW41oz/Sh3hcshGKecW6Qs1bqLj2YGq+8Fmgz6dd6vLB SK0oa8KDGP7xu8Tmhxtku1QKY8yHhZLuJH08kUFVz1FBm3UtlUYd0gQQlkgSdD1ULvtB bhyt/PEvp0Na7ooM3Y9n1LPfyxm3tmRgbTinVQDh1Ki/5SwQTIwuTwvBJbS+RnHbxolF pDTOuFHwwZa9Qnh0FPDEKw7gQY9UM4IjWZzvRwrwQa8ksrCyt+b2K8Hb1aY+wX4DZwhJ sYQA== X-Gm-Message-State: ALyK8tIxYyenq6G+dLEgZ/SAQqg8gZUA4TUHFgX0+aFmwhXD+fgnqlQRIv5dGh8sFA7CbO0jdQDEsdlwI5s5x/aa X-Received: by 10.157.1.165 with SMTP id e34mr18500663ote.35.1464608698129; Mon, 30 May 2016 04:44:58 -0700 (PDT) MIME-Version: 1.0 Received: by 10.157.31.87 with HTTP; Mon, 30 May 2016 04:44:28 -0700 (PDT) From: Pavel Tupitsyn Date: Mon, 30 May 2016 14:44:28 +0300 Message-ID: Subject: IgniteCache.invoke on ALL keys To: dev@ignite.apache.org Content-Type: multipart/alternative; boundary=94eb2c0c06742ff59105340dc9c3 archived-at: Mon, 30 May 2016 11:45:03 -0000 --94eb2c0c06742ff59105340dc9c3 Content-Type: text/plain; charset=UTF-8 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. --94eb2c0c06742ff59105340dc9c3--