Hi I would like a start a custom processor on Ignite Node. After exploring the source code, I have created a custom processor class that extends GridProcessorAdapter. I added the code to start custom processor just like other processors in IgniteKernal.java passing the GridKernalContextImpl ctx object. The custom processor will start a separate service on a separate Thread. I built the project and was able to see that my process was able to start when the Ignite node started.
This custom service that was started will use separate Threads which will do certain processing of data on the Ignite nodes on the cluster. The main operations performed by each Thread are : sql queries, cache get and puts and Ignite Transactions. I tried executing a query but the method is getting stuck forever. I used - QueryCursor<List<?>> qryCur = ctx.query().querySqlFieldsNoCache(Sql,false); where ctx is the GridKernalContextImpl object passed while starting the processor. I would like to know how to perform the query, cache, transaction operations using the GridKernalContextImpl object . Can this object be used by multiple Threads safely ? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/
