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 6B63C200B9A for ; Fri, 7 Oct 2016 22:46:29 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 69FE7160AE8; Fri, 7 Oct 2016 20:46:29 +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 AEB7D160AC6 for ; Fri, 7 Oct 2016 22:46:28 +0200 (CEST) Received: (qmail 86752 invoked by uid 500); 7 Oct 2016 20:46:27 -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 86740 invoked by uid 99); 7 Oct 2016 20:46:27 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 07 Oct 2016 20:46:27 +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 15753C044E for ; Fri, 7 Oct 2016 20:46:27 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.679 X-Spam-Level: * X-Spam-Status: No, score=1.679 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_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: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx2-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id J-6-KMSaFxB2 for ; Fri, 7 Oct 2016 20:46:25 +0000 (UTC) Received: from mail-qk0-f170.google.com (mail-qk0-f170.google.com [209.85.220.170]) by mx2-lw-eu.apache.org (ASF Mail Server at mx2-lw-eu.apache.org) with ESMTPS id 4B07A5FB5E for ; Fri, 7 Oct 2016 20:46:24 +0000 (UTC) Received: by mail-qk0-f170.google.com with SMTP id z190so40898372qkc.2 for ; Fri, 07 Oct 2016 13:46:24 -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 :cc; bh=SADTQ4/UrUKEwPDfcIEcWcKvjEnxcPHKvDh/N4S05eQ=; b=SmUChUGlgAYjEt6LRhWmJcVAlCQBrLeN6QJ7oUzwowNK/n9o+lT7isHNOG0uvTZ29X ujKEiGv+Q9unupWVZO1Fqq5OF7GsRtgGH5QiQ6Ab6oLB6hxTnrDmlEZbQTNif2qnwr0d URtytLXeFDVxK6j5Hr35oqSSvBAFR59gUNGJWYzG3k/WFAOJsZ/t/v11ZxsEF1bWfAAO +iInxVyu7CnTjGV6MH6oToMHcfWK0ieo3TaDPbT19eAOBw8pJ6kojY1SZ33pEb1WGD0j Ul8R1ym3YLJNFuTLZE7YXL9dzV7VU2BZM3mQzL/ySv9zj5po+txDR7d3Eb86jCm8D1Pc kIVA== 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:cc; bh=SADTQ4/UrUKEwPDfcIEcWcKvjEnxcPHKvDh/N4S05eQ=; b=SQ5zsoX9Ny29Ax+1I8/hXzWfOyuoACqgud+0pGkgTRuEE3DeNT16tlOWZq0ky6kENZ PFNbKreU6p0EkovzAtunIFDjb8647HIZj7NdvsveFxuVafmKMTn/ljrMdgz1dCXVJB2/ 34G5vXyB/eD2WEu1jF4o3ZusmeZyHJOfhholu9gGugDyrwj/xQ/png3c2Iay1JlHtc0V xRderKFlylL41jpYLs06A0MwbOL1P51d3jlik67LollDSd8vg6Y2ihBbUcASy7zj859A vbeG5apdC/+m2EmiKOP1cOVaQ8HCyeXxSz9dx2Jo9yfS46X8YGyKlYHBOx/d5AbeX4j9 Bjsg== X-Gm-Message-State: AA6/9RnC6OIcDXH1F20ZBy15NVJuTsl4sBppPAjM1UF3Mr8OeD5Jc2NV5dmj6fwkngpxIjBnaMScmOGCEvdnSQ== X-Received: by 10.55.88.199 with SMTP id m190mr22909401qkb.78.1475873176852; Fri, 07 Oct 2016 13:46:16 -0700 (PDT) MIME-Version: 1.0 Received: by 10.200.47.115 with HTTP; Fri, 7 Oct 2016 13:45:46 -0700 (PDT) In-Reply-To: References: From: Valentin Kulichenko Date: Fri, 7 Oct 2016 13:45:46 -0700 Message-ID: Subject: Re: Cassandra store questions To: Igor Rudyak Cc: dev@ignite.apache.org Content-Type: multipart/alternative; boundary=001a114e507e70a1ac053e4c8018 archived-at: Fri, 07 Oct 2016 20:46:29 -0000 --001a114e507e70a1ac053e4c8018 Content-Type: text/plain; charset=UTF-8 Hi Igor, Thanks for response! 1. It's a bit inconsistent with other store implementations we have in the product and actually I find this counterintuitive. Why don't we just load all the data available in the table? Explicit query is useful when you want to customize this and load subset of data based on some criteria. If this is not possible for some reason, then I would at least throw an exception in case query is not specified. 2. Is it possible to automatically split the data in bulks and load them in parallel? We do this in the JDBC store, for example. -Val On Thu, Oct 6, 2016 at 11:00 PM, Igor Rudyak wrote: > Hi Val, > > 1) If you'll call loadCache(null) it will do nothing. You need to provide > at least one CQL query. > > 2) It depends. If you'll provide more than one CQL query, it will use > separate thread for each of the queries (max number of threads limited to > the number of CPU cores). But for each provided CQL query it will use only > one thread to load all the data returned by the query. Also it will run the > same CQL query from ALL Ignite nodes to load the same data, which is bad. > That's because loadCache method will be executed on each Ignite node. As > you see, it's not very efficient way to load data from Cassandra just by > specifying CQL query. The ticket I created, is all about how to load data > from one table (or from multiple tables as well) in parallel by > partitioning it. Such a way each Ignite node will be responsible to load > data from the specific partition range of Cassandra table, which is much > more efficient. To support such kind of cache warm-up you should design > your Cassandra table specific way - there should be some mapping from > Ignite partition to the set of Cassandra partitions. Yes I have plans to > implement this. > > Igor Rudyak > > > On Thu, Oct 6, 2016 at 10:19 AM, Valentin Kulichenko < > valentin.kulichenko@gmail.com> wrote: > >> Hi Igor, >> >> I've got couple of quick questions about the Cassandra store. >> >> 1. In [1] you suggested to provide an explicit query as a parameter >> for loadCache() method, because otherwise user was always getting empty >> result. Is this a requirement to provide the query? What if I just call >> loadCache(null)? >> 2. There is a ticket [2] about parallel load in Cassandra store. Does >> it mean that currently it loads only in a single threaded fashion? If so, >> do you have any plans to implement this improvement? >> >> [1] http://apache-ignite-users.70518.x6.nabble.com/Cannot- >> query-on-a-cache-using-Cassandra-as-a-persistent-store-td7870.html >> [2] https://gridgain.freshdesk.com/helpdesk/tickets/2180 >> >> Thanks, >> Val >> > > --001a114e507e70a1ac053e4c8018--