Toggle navigation
Home
org.apache.ignite.internal.IgniteInternalFuture to java.lang.management.PlatformManagedObject
No. of Instances - 3
No. of Commits - 2
No. of Projects - {'ignite'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Cascading Type Change (Different)
IgniteInternalFuture<Map<Integer,String>>
to
IgniteCache<Integer,String>
Collection<Integer>
to
Set<Integer>
ArrayList<>
to
TreeSet<>
GridCache<Integer,String>
to
IgniteCache<Integer,String>
Add or Remove Method invocation
exec.submit(new Callable<Void>(){ @Override public Void call() throws Exception { IgniteCache<Integer,String> cache=ignite.cache(null); Random random=new Random(); while (!finish.get()) { Set<Integer> keys=new TreeSet<>(getKeyNum); for (int i=0; i < KEYS_NUM; i++) { Integer key=KEYS[randomGet ? random.nextInt(KEYS_NUM) : i]; keys.add(key); if (keys.size() == getKeyNum) { sem.acquire(); IgniteCache<Integer,String> f=cache.getAllAsync(keys); f.listenAsync(lsnr); cntr.incrementAndGet(); keys.clear(); } } } return null; } } )
to
exec.submit(new Callable<Void>(){ @Override public Void call() throws Exception { IgniteCache<Integer,String> cache=ignite.jcache(null); Random random=new Random(); while (!finish.get()) { Set<Integer> keys=new TreeSet<>(); for (int i=0; i < KEYS_NUM; i++) { Integer key=KEYS[randomGet ? random.nextInt(KEYS_NUM) : i]; keys.add(key); if (keys.size() == getKeyNum) { sem.acquire(); IgniteCache<Integer,String> asyncCache=cache.withAsync(); asyncCache.getAll(keys); IgniteFuture<Object> f=asyncCache.future(); f.listenAsync(lsnr); cntr.incrementAndGet(); keys.clear(); } } } return null; } } )
Rename Variable
getAndPutIfAbsentAsync
to
getAndPutIfAbsent