Re: Charming Ignite Spark stack

2015-06-12 Thread MrAsanjar .
thanks Yakov On Fri, Jun 12, 2015 at 6:06 AM, Yakov Zhdanov yzhda...@apache.org wrote: I have created the ticket - https://issues.apache.org/jira/browse/IGNITE-1014 Anyone from community wants to pick it up? --Yakov 2015-06-03 18:24 GMT+03:00 MrAsanjar . afsan...@gmail.com: Hi all

Re: logging

2015-06-12 Thread Jonathon Bell
Hi All, I have a question about the way the publish-subscribe topic based messaging system is implemented in ignite. I wish to send a large number of messages to *n *different tasks, each potentially running on its own node. When sending each message, i know the exact unique task that should

logging

2015-06-12 Thread Jonathon Bell
Hi all, My application uses SLF4J and LOGBACK for logging. Is it possible for me to configure the ignite libraries to use this logging combination too? If so, how? n.b: i tried adding the line: groupIdorg.apache.ignite/groupId artifactIdignite-slf4j/artifactId

Re: Topology Specification INI

2015-06-12 Thread Jonathon Bell
Thanks for the quick response. Now for some followup questions :-) 1) where can i learn more more about the various parameters that can be specified in the grid configuration xml file? (files such as examples/config/ignite.xml?) . How do is specify the 'grid name', for example, that shows up in

Re: logging

2015-06-12 Thread Valentin Kulichenko
Jonathon, IgniteMessaging facade can be created for a cluster group (see message(ClusterGroup grp) method). So you can create a cluster group with only one receiver node and create IgniteMessaging instance for this group. All messages sent through this instance will be sent to that node only. The

Re: Trouble Enabling Query Indexing

2015-06-12 Thread Valentin Kulichenko
Fluffy, You have a cache configuration in both code and XML. The one in XML is actually used, but it doesn't provide indexed types. Your code configuration looks correct, so I think you should simply remove it from XML. -Val On Fri, Jun 12, 2015 at 1:39 PM, fluffy fhaf...@gmail.com wrote: I

Re: logging

2015-06-12 Thread Valentin Kulichenko
Jonathon, You should also configure SLF4J logger in configuration: Slf4jLogger gridLog = new Slf4jLogger(slf4jLog); // Provide correct SLF4J logger here. igniteCfg.setGridLogger(gridLog); Let us know if it helps. -Val On Fri, Jun 12, 2015 at 1:04 PM, Jonathon Bell jonathon.a.b...@gmail.com

Re: scala.pickling and sql in Ignite

2015-06-12 Thread Alexey Goncharuk
Ognen, Current implementation of SQL uses reflection to inspect stored objects and extract field values for indexing. Both JSON format and scala pickling do not have any fields visible to reflection, which makes it impossible to use them in indexing. There is though a pluggable indexing SPI, so

Re: When putting data on Off heap Cache Consuming all RAM

2015-06-12 Thread dsetrakyan
Abhishek M wrote I have 25 Millions Records. When i am putting into Off_Heap cache its consuming 14Gb Memory(near about 10Gb Ram + 4Gb Swap). Please let me know how i can reduce the memory size. their is any option so that it will consume less memory? While i am putting same data in Java

Re: Trouble Enabling Query Indexing

2015-06-12 Thread dsetrakyan
fluffy wrote I'm having the same issue with the latest release. Did you ever find a solution or this? Forian, does the solution provided in this thread with @ScacheCacheQuerySqlField annotation work for you? D. - D. -- View this message in context:

Re: Integration of MongoDB

2015-06-12 Thread dsetrakyan
daliborn wrote I have an big mongoDB store, but I'm not sure how can I integrate datagrid with mongo? I would like to have faster fetch of records. I believe you can implement a simple MongoCacheStore as described here: http://apacheignite.readme.io/v1.1/docs/persistent-store There is also an

Re: Trouble Enabling Query Indexing

2015-06-12 Thread leroyJr
Fluffy, We ended up using the @ScalarCacheQuerySqlField annotation that dsetrakyan suggested. Additionally we had limited success depending on the key type being indexed. Take a look at http://apache-ignite-users.70518.x6.nabble.com/SQL-query-question-tc426.html When we used Scala's Int as a