Re: How to run Ignite REST API scan query with predicate

OK, May be I wasn't clear before. Lets say cache contains entries 1. Trade1-> TradeObject{field1 =2, other fields} Trade2-> TradeObject{field1 =3, other fields} Trade3-> TradeObject{field1 =2, other fields} Now if I run scan query without filter, it will return above 3 entries. But

Re: How to run Ignite REST API scan query with predicate

Ok Even if i add default constructor, how do I pass parameters of this class to query ? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: How to run Ignite REST API scan query with predicate

Yes, Predicate class is public and implement appy(). But I am trying to understand how to set the fields of the predicate class. It has a constructor which takes two parameters public TradeObjectPredicate(String tradeObjectField1, Set tradeObjectField2List){ . } How to pass these values

How to run Ignite REST API scan query with predicate

Hi Guys, I have an ignite cache of type distributed over several nodes. I want to query its data using ignite REST APIS as mentioned https://apacheignite.readme.io/v2.6/docs/rest-api#sql-scan-query-execute I am able to query the cache without predicate and page size

Querying Ignite caches in DBeaver

Hey Guys... I am trying to use DBeaver for querying cache data in ignite cluster. I can run simple queries like 'select * from "persons".Person' and it shows all the records of it. I have below queries: 1. Is there a way to list of all caches of cluster in DBeaver SQL Editor 2. Does DBeaver only

How many threads does ignite.executorService() have.

Hi Guys, I have one simple query about ignite executor service. I know java executor service accepts the no of threads to be run, but there is no option to pass no of threads to ignite executor service. So how does it manage threads to be started. many thanks -- Sent from:

Re: NullPointer Exception in Continuous Query

Thanks for reply, but unfortunately, I could understand the details in the link provided. Could you please brief about it. Whats the root cause. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

NullPointer Exception in Continuous Query

Hi, I am getting this exception in logs but not sure on which cache it is happening. Logs does not help me identifying the cache either. Apologies to ask here without much details but just wondering if someone know what are the chances to get this exception. I have set of caches and CacheMode is

Re: Auto sync caches with database

Hi, We are already using 3rd party datastore feature in our application using cache Stores. I was reading out Hazlecast hot cache feature and thats how I got this question. It would be big advantage if something like that possible in ignite. https://hazelcast.com/resources/keeping-cache-hot/

Auto sync caches with database

Hi, I have been working with apache ignite 1.9 for quite sometime now and one common problem which I faced is adding new records to cache from external systems. Ignite currently don't provide auto sync capability with database. So I have to write logic to insert entries to cache whenever new data

Re: get() function in ignite cache

Thanks. This is awesome! -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

get() function in ignite cache

HI Guys, I am using cache.get() on ignite cache. Its readThrough cache so it means cache.get() will load entry from cacheStore if not in cache. But in one place, I want to get only from cache, so it should not go to backstore to load the entry. Is there a get version which accomplish that. Does

Re: Ignite cache query

e.g. public class Student { @QuerySqlField(index=true) int id; @QuerySqlField String name ; @QuerySqlField LocalDateTime dob; @QuerySqlField LocalDate dos; @QuerySqlField Map> map = new

Re: Ignite cache query

You need to annotate you POJO fields with @QuerySqlField. This annotation will make them visible to SQL queries on the cache. Also, you can add indexes to these fields for better performance. Both, Java and XML configurations are available See

How Ignite manages primary and secondary nodes

Hi, I am bit confused about how ignite manages which nodes is primary and secondary. Every distributed grid has some node which has information about primary and secondary nodes so if primary goes down, one of primary is made secondary which out any data loss(loss here means if primary node data

Re: Effective Data through DataStream

I dont understand why you need to define receiver to update value in the cache. streamer does is for you. you just need to write something like this try (IgniteDataStreamer streamer = ignite.dataStreamer("cacheName")) { for(Entry entry : maps.entrySet()){

Re: Failed to wait for partition map exchange

Could you please paste complete log. This log is not enough. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Ignite Sql Query Execution time is too long

Have you tried adding indexes to frequently searched fields ? Indexing can make searching the cache quite faster -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Data Streamer not flushing data to cache

One more query.. Would it never flush the data if nothing more is added to streamer and current size is less than buffer size ? What is the default time. I can see only flush frequency -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Data Streamer not flushing data to cache

Thanks for reply... Its works after invoking flush(). -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Data Streamer not flushing data to cache

Hi, This must be something very simple. I am adding 100 items to data streamer. But it is not flushing items to cache. Is there a settings much enables it. Cache size is zero. Am I doing something wrong ? public class DataStreamerExample { public static void main(String[] args) throws

Re: Basic terms in Ignite

Thanks Dave for very informative reply. I will come back with some more questions Regards, -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Basic terms in Ignite

Hi, I am confused about few terms used often in ignite docs. Could someone please clarify them. 1. What is difference between a Server, JVM and ignite node. Can one have multiple instances of other 2, like a jvm has two nodes or a node has 2 jvms. Please explain in detail, I am very confused

Re: Using igniteAtomicLong or igniteAtomicSequence as uniqueId in ignite cache

Thanks for reply. Surely this should work.Just one query. Will it work in distributed environment. We have a grid of nodes and I am trying to do it in a way that it should be working on cluster of nodes than just one jvm. Regards -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Continuous Query remote listener misses some events or respond really late

Hi.. I know its quite late to reply, But I am seeing this issue intermittently almost everyday. But can't reproduce it locally on dev machine. As suggested I have moved logs before null check to see if null event is logged. However, I didn't see it printed in logs. Also, it was suggested to check

Using igniteAtomicLong or igniteAtomicSequence as uniqueId in ignite cache

Hi, My application submits heavy requests from UI which are run in async and request Id is stored in ignite cache and other request details as value. I was looking for a way to generate request id. One way to use AtlomicInteger but that will not support distributed behavior. So I found

Re: Thread Pool Starvation in ignite grid

Sure, will check the heap stats.And this is not local node. Its happening in QA environment which has 12 servers connected to grid. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Thread Pool Starvation in ignite grid

Hi, Any one to the rescue here please.I am finding it hard to understand these logs. When this starts happening, ignite grid just stops working. Nothing works unless grid is restarted. Any helpful would be grateful. Error log: [2017-09-07/13:16:47.856/BST][WARN

Re: Serialization exception in Ignite compute job

HI, Thanks. Its clear now. And it solved the issue. Thanks again -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Serialization exception in Ignite compute job

Hi, I am submitting a compute job to ignite compute grid, It worked one time but now its failing every time. My compute task is Ignite Runnable so it is serializable but enclosing class is not. I think outer class does not need to be serializable because inner class is not anonymous. /** this

Ignite SQL Queries on Lists fields sorting

hey Guys, I have a question about Ignite Sql Queries. Let say my cache looks like below sample code. If I add orderBy clause on subjectMarksList, how will it sort it. Compare values in list by index or how. I coudn't find anything in docs. Cache class Student{ int id; String

Re: Continuous Query remote listener misses some events or respond really late

Thanks, In my application, all nodes are server nodes And how do we be sure that nodes removed/ reconnect to grid is CQ node, it can be any. Also, Is this issue possible in all below scenarios? 1. if node happens to be CQ node or any node? 2. node is removed from grid forcefully(manual shutdown)

Re: Continuous Query remote listener misses some events or respond really late

Umm. actually nothing get logged in such scenario. However, as you indicated earlier, I could see trades get stuck if a node leaves the grid(not always). Do you know why that happens? Is that a bug? -- View this message in context:

Re: Continuous Query remote listener misses some events or respond really late

1) How you use ContinuousQuery: with initialQuery or without? : with initial query having same predicate 2) Did some nodes disconnect when you loose updates? no 3) Did you log entries in CQ.localListener? Just to be sure that error in CQ logic, not in your service logic. : No log entries in

Re: Continuous Query remote listener misses some events or respond really late

Hi Thanks for looking into this. Its not easily reproduce-able. I only see it some times. Here is my cache and service configuration Cache configuration: readThrough="true" writeThrough="true" writeBehindEnabled="true" writeBehindFlushThreadCount="5" backups="1" readFromBackup="true" service

Continuous Query remote listener misses some events or respond really late

Hi, I am currently facing intermittent issue with continuous query. Cant really reproduce it but if any one faced this issue, please do let me know My application is deployed on 12 nodes with 5-6 services are used to detect respective events using continuous query. Lets say I have a cache of type

Re: Detecting terminal condition for group of items in Ignite cache.

Thanks for reply first of all. Well I had this in back of my mind but it will be like duplicating the data which we already have in other cache(trades cache which I am currently querying). So other way I can think of is using spring scheduler with 1 minute fix-rate and check if any item moved to

Detecting terminal condition for group of items in Ignite cache.

Hi, My sample application processes trades for different companies stored in Ignite cache. When all trades for particular company reaches SUCCESS stage, an automatic notification should be triggered and some other system/application will react to it. To do this, When ever any trade reaches SUCCESS

Re: Building complex queries to query ignite Cache

Thanks for reply. This is perfect and much simpler if I have to get counts of various statuses. Although using this approach to build 3D kind of mapping(i.e. sample table shown in reply 2 in this thread) requires a lot of manipulation to data. Thanks all for help. Will come back again if more

Re: Building complex queries to query ignite Cache

Hi, Thanks for reply. I need this map to build a dashboard UI page which looks like below(image attached). So specific part of entries would still be more than 100,000 items which is minimum as data set for given input parameters. So just wondering if some inbuilt query could help me here.

Building complex queries to query ignite Cache

Hi, I have below sample bean which I am storing as value in cache. I want to build a map such that it gives me count of trade status for each trade type(Pls see sample output, done thru java 8 streams). Problem with this approach is I have to pull millions of entries from cache to some collection

Re: Getting exception in SQL Query JOINS

OK thanks -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Getting-exception-in-SQL-Query-JOINS-tp6674p7228.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Getting exception in SQL Query JOINS

I have one more related question to this, Is there a limit to size of array passed. If we use IN clause, Oracle allows maximum size of 1000 -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Getting-exception-in-SQL-Query-JOINS-tp6674p7203.html Sent from the Apache

Re: Getting exception in SQL Query JOINS

Thanks it worked I changed my code as below query1.setArgs(new Object[] {args1.toArray()}); -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Getting-exception-in-SQL-Query-JOINS-tp6674p6867.html Sent from the Apache Ignite Users mailing list archive at

Re: SQLQuery JOIN does not accept multiple parameters in list/array as placeholder.

Thanks It worked ! -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/SQLQuery-JOIN-does-not-accept-multiple-parameters-in-list-array-as-placeholder-tp6837p6868.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: SQLQuery JOIN does not accept multiple parameters in list/array as placeholder.

Can some one please reply to this. Is it a bug or I am doing something wrong. -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/SQLQuery-JOIN-does-not-accept-multiple-parameters-in-list-array-as-placeholder-tp6837p6854.html Sent from the Apache Ignite Users

SQLQuery JOIN does not accept multiple parameters in list/array as placeholder.

Hi, I am trying to use SqlQuery JOIN clause as mentioned in below link which is work around to avoid IN clause of Sql Query. As mentioned in docuents, we can pass array or lits of parameters, but query does not accept array or list with more than one parameter

Re: Getting exception in SQL Query JOINS

Does it work for single parameter only. If I pass list to query.setArgs(), I get below exception If I pass single value to setArgs, it works fine. BUt it does not accept list/array of values. Failed to execute query... Caused by: org.h2.jdbc.JdbcSQLException: Data conversion error converting

Re: Getting exception in SQL Query JOINS

So What I mean is I need to get data from cache which has keys in the list I pass to query. equavalent SQL will be like, List list = Arrays.asList(2,3,6);//dynamic list coming from client StringBuffer queryStrings = new StringBuffer(" "); for

Re: Getting exception in SQL Query JOINS

Cant we have multiple indexTypes for one cache. I have created my configuration from below Ignite Documentations: https://apacheignite.readme.io/docs/sql-queries#configuring-sql-indexes-using-queryentity

Re: Getting exception in SQL Query JOINS

Thanks... It did not help. I cannot use getAll() because I want to get all records which matches the Ids passed dynamically. -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Getting-exception-in-SQL-Query-JOINS-tp6674p6697.html Sent from the Apache Ignite Users

Getting exception in SQL Query JOINS

I want to get data from ignite cache for list of keys which I can pass in IN clause of SQL Query. BUt since IN does not take dynamic parameters, I followed this link to use JOIN to perform my task,

Re: Is there any such thing as SQlBuilder in apache Ignite for SQLQuery

basically, that does not help me. There will be multiple requests coming to query the cache which will need data between limit and Offset. PageSize helps in how data is fetched from cache(i.e in batches of pageSize). but not for pagination to UI. For example, top 20 for 25th July, may be next

Re: Ignite - Using - complex object with nested attributes and search

vkulichenko, I have an example where I store Employee object in cache. public class Employee { @QuerySqlField(index=true) private String name; @QuerySqlField(index=true) private List addresses; } public class Address { private String street;

Is there any such thing as SQlBuilder in apache Ignite for SQLQuery

I am using sql queries to implement pagination in ignite cache. Below is my code to build sql to be passed to SQLQuery. It looks very messy as there are lot of checks and if else. Is there something in ignite like builder which will do the task? String sql = " select * from Employee" private

Re: cursor.getAll() throws NoSuchMethodError excepion when SqlQuery is executed

With the help of Ignite community member, it is resolved. I was using two different versions of ignite components in different modules of application. Thanks ! -- View this message in context:

cursor.getAll() throws NoSuchMethodError excepion when SqlQuery is executed

I am getting below exception when i call getAll() on cursor returned from SqlQuery. My POJO class fields are annotated with @QuerySqlField(index=true) except the ones which are collections(Set and Lits of other cutom Objet. I have enabled indexing in cache using below configuration

Re: Column not found exception while running SqlQuery i Ignite.

Hi Thanks, Sorry for typo, It still does not work. -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Column-not-found-exception-while-running-SqlQuery-i-Ignite-tp6464p6480.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.