Toggle navigation
Home
org.apache.ignite.internal.util.typedef.T2<V, org.apache.ignite.internal.processors.cache.version.GridCacheVersion> to org.apache.ignite.internal.processors.cache.EntryGetResult
No. of Instances - 7
No. of Commits - 1
No. of Projects - {'ignite'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Different)
CX1<IgniteInternalFuture<T2<V,GridCacheVersion>>,CacheEntry<K,V>>
to
CX1<IgniteInternalFuture<EntryGetResult>,CacheEntry<K,V>>
UpdateGetTimeStatClosure<T2<V,GridCacheVersion>>
to
UpdateGetTimeStatClosure<EntryGetResult>
CX1<IgniteInternalFuture<Map<K,T2<V,GridCacheVersion>>>,Collection<CacheEntry<K,V>>>
to
CX1<IgniteInternalFuture<Map<K,EntryGetResult>>,Collection<CacheEntry<K,V>>>
UpdateGetTimeStatClosure<Map<K,T2<V,GridCacheVersion>>>
to
UpdateGetTimeStatClosure<Map<K,EntryGetResult>>
Update Anonymous class
{ @Override public CacheEntry<K,V> applyx( IgniteInternalFuture<T2<V,GridCacheVersion>> f) throws IgniteCheckedException { T2<V,GridCacheVersion> t=f.get(); K key=keepBinary ? (K)ctx.unwrapBinaryIfNeeded(key0,true,false) : key0; CacheEntry val=t != null ? new CacheEntryImplEx<>(key,t.get1(),t.get2()) : null; if (intercept) { V val0=(V)ctx.config().getInterceptor().onGet(key,t != null ? val.getValue() : null); return val0 != null ? new CacheEntryImplEx(key,val0,t != null ? t.get2() : null) : null; } else return val; } }
to
{ @Override public CacheEntry<K,V> applyx( IgniteInternalFuture<EntryGetResult> f) throws IgniteCheckedException { EntryGetResult t=f.get(); K key=keepBinary ? (K)ctx.unwrapBinaryIfNeeded(key0,true,false) : key0; CacheEntry val=t != null ? new CacheEntryImplEx<>(key,t.value(),t.version()) : null; if (intercept) { V val0=(V)ctx.config().getInterceptor().onGet(key,t != null ? val.getValue() : null); return val0 != null ? new CacheEntryImplEx(key,val0,t != null ? t.version() : null) : null; } else return val; } }
{ @Override public Collection<CacheEntry<K,V>> applyx( IgniteInternalFuture<Map<K,T2<V,GridCacheVersion>>> f) throws IgniteCheckedException { if (intercept) return interceptGetEntries(keys,f.get()); else { Map<K,CacheEntry<K,V>> res=U.newHashMap(f.get().size()); for ( Map.Entry<K,T2<V,GridCacheVersion>> e : f.get().entrySet()) res.put(e.getKey(),new CacheEntryImplEx<>(e.getKey(),e.getValue().get1(),e.getValue().get2())); return res.values(); } } }
to
{ @Override public Collection<CacheEntry<K,V>> applyx( IgniteInternalFuture<Map<K,EntryGetResult>> f) throws IgniteCheckedException { if (intercept) return interceptGetEntries(keys,f.get()); else { Map<K,CacheEntry<K,V>> res=U.newHashMap(f.get().size()); for ( Map.Entry<K,EntryGetResult> e : f.get().entrySet()) res.put(e.getKey(),new CacheEntryImplEx<>(e.getKey(),(V)e.getValue().value(),e.getValue().version())); return res.values(); } } }