Re: IgniteDataStreamer

Thank you - going to trying this in a bit. -gene -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: IgniteDataStreamer

Thank you Thomas, I did not even know the star "*" makes a CacheConfiguration bean registered as a template. I am not sure Ignite has it documented anywhere.

RE: IgniteDataStreamer

uot;cache_name" your cache will be called "SQL_PUBLIC_MYCACHE" ./t -Original Message- From: gene [mailto:gene.foj...@gm.com] Sent: tirsdag 16. januar 2018 04.31 To: user@ignite.apache.org Subject: Re: IgniteDataStreamer I saw that method. But the 2.3 for CREATE TABLE indicat

Re: IgniteDataStreamer

I saw that method. But the 2.3 for CREATE TABLE indicates you can passing by WITH for the template. WITH - accepts additional parameters not defined by ANSI-99 SQL: TEMPLATE= - case-sensitive​ name of a cache template registered in Ignite to use as a configuration for the distributed cache that i

Re: IgniteDataStreamer

I do not think there is a way to add a cache template via XML configuration file. You have to write code ignite.addCacheConfiguration(cacheTemplate) where cacheTemplate is an instance of CacheConfiguration that you reference from CREATE TABLE ... WITH "template=NAME" by NAME.

Re: IgniteDataStreamer

thank you. -g -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: IgniteDataStreamer

Thank you. I've moved past this issue now and have been able to create Table/Cache's using the DDL and WITH parameters. The only issue I'm facing now is how to register a cache template that I can call using the WITH Template= -g -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: IgniteDataStreamer

Just in case you can set a meaningful cache name using CACHE_NAME property of CREATE TABLE command: https://apacheignite-sql.readme.io/docs/create-table — Denis > On Dec 11, 2017, at 1:12 AM, Alexey Kukushkin > wrote: > > You can access

Re: IgniteDataStreamer

You can access a cache created with DDL (CREATE TABLE) from Java API including IgniteDataStreamer API by prepending "SQL_PUBLIC_" to the capitalised table name. For example, if you created a table as "create table person ... " then you can access if from Java API as ignite.dataStreamer("SQL_PUBLIC_

Re: IgniteDataStreamer with Continuous Query

Hi, You need to put the continuous query execution statement out of the try-with-resource block. So, the code has to look like this QueryCursor> cur = stmCache.query(continuousQuery); for(Cache.Entry c : cur) { System.out.println(c);

Re: IgniteDataStreamer with Continuous Query

Can someone please have a look at below query? Thanks On Dec 29, 2016 2:13 PM, "Ankit Singhai" wrote: > Hi, > In my test case scenario I am pumping data into cache via data streamer > which has Created expiration policy of 60 seconds to have sliding window of > 60 seconds, after the initial bur

Re: IgniteDataStreamer with Continuous Query

Hi, In my test case scenario I am pumping data into cache via data streamer which has Created expiration policy of 60 seconds to have sliding window of 60 seconds, after the initial bursts I am making my thread to sleep then again pump data, but for the 2nd bursts I am not getting any events (local

Re: IgniteDataStreamer with Continuous Query

Thanks On Dec 28, 2016 7:12 PM, "dkarachentsev" wrote: > Hi Ankit, > > Yes, you can use ContinuousQuery with DataStreamer. Code samples you may > found here [1] and [2]. > > [1] > https://github.com/apache/ignite/blob/master/examples/ > src/main/java/org/apache/ignite/examples/streaming/ > Strea

Re: IgniteDataStreamer with Continuous Query

Hi Ankit, Yes, you can use ContinuousQuery with DataStreamer. Code samples you may found here [1] and [2]. [1] https://github.com/apache/ignite/blob/master/examples/src/main/java/org/apache/ignite/examples/streaming/StreamTransformerExample.java [2] https://github.com/apache/ignite/blob/master/e

Re: IgniteDataStreamer can't wirte data to ignite cluster

Continue discussion here http://apache-ignite-users.70518.x6.nabble.com/IgniteDataStreamer-can-t-wirte-data-to-ignite-cluster-tt7012.html -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/IgniteDataStreamer-can-t-wirte-data-to-ignite-cluster-tp7003p7018.html Sent f

Re: IgniteDataStreamer can't wirte data to ignite cluster

Hello, The issue with grid segmented: The reasons of this may be long garbage collector pause, long pause of process of user layer due to process of system kernal work, network problem (like break). By steps: 1) Update ignite version, because the 1.5.0 is very old. 1.7.0 is already available. 2

Re: IgniteDataStreamer lose data in multithreading?

Hi, Please properly subscribe to the mailing list so that the community can receive email notifications for your messages. To subscribe, send empty email to user-subscr...@ignite.apache.org and follow simple instructions in the reply. And please clarify the question. What is not working for you?