ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pgarg <pg...@gridgain.com>
Subject Re: Serialization Exception when trying to query cache on remote node.
Date Sat, 09 May 2015 07:57:11 GMT
/commented by alexey goncharuk/

John,

You do not need to broadcast a closure which executes your SQL query on all
nodes. In fact, this is essentially what happens under the covers when you
ask Ignite to execute an SQL query.

In your case, you should get rid of broadcast(...) call altogether and run

*/String sqlStr = "FROM MyTrx2 WHERE fullName = ?";
SqlQuery sql = new SqlQuery(MyTrx2.class, sqlStr);
sql.setArgs(trxRequest.getFullName());
sql.setLocal(true);
HashSet<Map.Entry> list = new
HashSet<>(myCache.query(sql.setSql(sqlStr)).getAll());/*

right away instead.

As a side note notice that I changed the generic type of the hash set
because an SQL query returns collection of */Map.Entry/* objects.

----- 
/This post is migrated from now discontinued Apache Ignite forum at 
http://apacheignite.readme.io/v1.0/discuss/




--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Serialization-Exception-when-trying-to-query-cache-on-remote-node-tp162p163.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Mime
View raw message