Apache Ignite のドキュメントを読んで、(たとえば) Eclipse で使用したクラスが、Ignite サーバーの分散インスタンスに自動的に (あえて言えば魔法のように?) 送信されるという印象を受けました。
私は3つのバニラサーバーを持っており、実行中のカスタムクラスはロードされていません (./bin/ignite.sh) 、すべてローカルホスト上にあります。彼らはとてもよく見つめます。
キャッシュにロードするために使用する 1 つのカスタム クラスで Eclipse プログラムを実行します。単純な POJO、シリアライズ可能など。
計算コードを実行しようとすると、リモート サーバーがクラス ローダーにクラスがないと文句を言います。
Caused by: java.lang.ClassNotFoundException: com.company.dms.ignite.batch.model.MessageCustAccount
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:348)
at org.apache.ignite.internal.util.IgniteUtils.forName(IgniteUtils.java:8213)
at org.apache.ignite.internal.MarshallerContextAdapter.getClass(MarshallerContextAdapter.java:185)
at org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:607)
... 29 more
魔法はもっとありますか？
ExecutorService exec = ignite.executorService(ignite.cluster().forRemotes());
// Iterate through all words in the sentence and create jobs.
quickCounter = 10;
while(it.hasNext() && quickCounter-- > 0){// "Print words using runnable".split(" ")) {
final String word = it.next();
// Execute runnable on some node.
String interna_cache_name = DMSIgniteHelpers.getInstance().getCurrentCacheLocation(ignite, MSG_CUST_ACCT_CACHE);
exec.submit(new IgniteRunnable() {
@Override public void run() {
String delimeter = "\u0001";
String[] lineTokens = word.split("\\"+delimeter);
String three_pk = null;
if(lineTokens[2].toString() != null && lineTokens[4].toString() != null && lineTokens[3] != null) {
String sor_id = new Integer(lineTokens[2]).toString();
String cust_id = new Long(lineTokens[4]).toString();
String acct_id = lineTokens[3];
three_pk = sor_id + cust_id + acct_id;
System.out.println("Looking for ("+sor_id+") ("+cust_id+") ("+acct_id+") : " + three_pk + " ----- ");
System.out.println("Going to query cache: " + interna_cache_name);
IgniteCache<Integer, MessageCustAccount> msgCustAccountCache = ignite.cache(interna_cache_name);
MessageCustAccount a = sqlQuery(msgCustAccountCache,three_pk);
System.out.println("*************=================\n\n" + a.toString() + "\n@#$@#$@#$@#$@#$@#$@#$@#$@#$@#$@#$");
}
System.out.println(">>> Printing '" + word + "' on this node from grid job.");
}
});
}