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 66A60200D4F for ; Wed, 6 Dec 2017 15:19:31 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 655BA160C08; Wed, 6 Dec 2017 14:19:31 +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 ACA30160BFD for ; Wed, 6 Dec 2017 15:19:30 +0100 (CET) Received: (qmail 57152 invoked by uid 500); 6 Dec 2017 14:19:29 -0000 Mailing-List: contact user-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@ignite.apache.org Delivered-To: mailing list user@ignite.apache.org Received: (qmail 57143 invoked by uid 99); 6 Dec 2017 14:19:29 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 06 Dec 2017 14:19:29 +0000 Received: from mail-qt0-f169.google.com (mail-qt0-f169.google.com [209.85.216.169]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 428141A0158 for ; Wed, 6 Dec 2017 14:19:29 +0000 (UTC) Received: by mail-qt0-f169.google.com with SMTP id e2so9300578qti.0 for ; Wed, 06 Dec 2017 06:19:29 -0800 (PST) X-Gm-Message-State: AKGB3mKsmPrzNQ/tWDd2qOToaGQQkQA3pJvmrEV3Zu3LEBy518HqfVKn GAAKIhLnhfkSTGBmV2aD8rLj5nUPi0+pQbgyFzddWQ== X-Google-Smtp-Source: AGs4zMaR/qhE4LKKiZJYripNsw9oKzIislXk8FHjUKNeb6dGxLPJDROdBJ63neEXRGU8Yd6o3GZL2dEW9+sQf0O+nUA= X-Received: by 10.55.157.133 with SMTP id g127mr24352560qke.280.1512569968006; Wed, 06 Dec 2017 06:19:28 -0800 (PST) MIME-Version: 1.0 Received: by 10.237.59.184 with HTTP; Wed, 6 Dec 2017 06:19:27 -0800 (PST) In-Reply-To: <1512495139606-0.post@n6.nabble.com> References: <1512491423092-0.post@n6.nabble.com> <1512495139606-0.post@n6.nabble.com> From: Nikolai Tikhonov Date: Wed, 6 Dec 2017 17:19:27 +0300 X-Gmail-Original-Message-ID: Message-ID: Subject: Re: DataStreamer vs CacheStoreAdapter To: user@ignite.apache.org, Lybrial@googlemail.com Content-Type: multipart/alternative; boundary="001a114d8ad4a431b1055faca3fa" archived-at: Wed, 06 Dec 2017 14:19:31 -0000 --001a114d8ad4a431b1055faca3fa Content-Type: text/plain; charset="UTF-8" Hi, If you plan to stream into data from single JVM then the better way use only one instance of DataStreamer. Sure, if you're going to start different 10 JVMs than you'll use 10 instance of DataStreamer. By default DataStreamer won't overwrite existing entries in a cache. You can change this behaviour IgniteDataStreamer#allowOverwrite(true) via method [1]. 1. https://apacheignite.readme.io/docs#section-allow-overwrite On Tue, Dec 5, 2017 at 8:32 PM, Lybrial wrote: > Hi, > > I guess I did not understand what you mean for the DataStreamer. When I > have > a distributed > database (or distributed files maybe) I want to be able to load all of > these > resources simultaneously > into the same cache since there arent duplicates. the resources are > distinct > from each other. So > in my example I would not have one DataStreamer per cache, I would have 10 > DataStreamers > for one cache. > > > > -- > Sent from: http://apache-ignite-users.70518.x6.nabble.com/ > --001a114d8ad4a431b1055faca3fa Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Hi,

If you plan to stream into da= ta from single JVM then the better way use only one instance of DataStreame= r. Sure, if you're going to start different 10 JVMs than you'll use= 10 instance of DataStreamer.
By default DataStreamer won't overwr= ite existing entries in a cache. You can change this behaviour IgniteDataSt= reamer#allowOverwrite(true) via method [1].=C2=A0

<= div>1. https://apacheignite.readme.io/docs#section-allow-overwrite

On Tue, D= ec 5, 2017 at 8:32 PM, Lybrial <Lybrial@googlemail.com>= wrote:
Hi,

I guess I did not understand what you mean for the DataStreamer. When I hav= e
a distributed
database (or distributed files maybe) I want to be able to load all of thes= e
resources simultaneously
into the same cache since there arent duplicates. the resources are distinc= t
from each other. So
in my example I would not have one DataStreamer per cache, I would have 10<= br> DataStreamers
for one cache.

--001a114d8ad4a431b1055faca3fa--