org.infinispan.CacheSet to java.util.concurrent.CompletableFuture
No. of Instances - 10
No. of Commits - 1
No. of Projects - {'infinispan'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
- Add or Remove Method invocation
- getCacheWithFlags(cache,command) to Caches.getCacheWithFlags(cache,command)
- getCacheWithFlags(cache,command) to Caches.getCacheWithFlags(cache,command)
- getCacheWithFlags(cache,command) to Caches.getCacheWithFlags(cache,command)
- getCacheWithFlags(cache,command) to Caches.getCacheWithFlags(cache,command)
- getCacheWithFlags(cache,command) to Caches.getCacheWithFlags(cache,command)
- getCacheWithFlags(cache,command) to Caches.getCacheWithFlags(cache,command)
- Other
- new AbstractDelegatingKeyCacheSet(Caches.getCacheWithFlags(cache,command),set){ @Override public CloseableIterator<K> iterator(){ return new TransactionAwareKeyCloseableIterator<>(super.iterator(),(TxInvocationContext<LocalTransaction>)ctx,cache); } @Override public CloseableSpliterator<K> spliterator(){ Spliterator<K> parentSpliterator=super.spliterator(); long estimateSize=parentSpliterator.estimateSize() + ctx.getLookedUpEntries().size(); return new IteratorAsSpliterator.Builder<>(iterator()).setEstimateRemaining(estimateSize < 0L ? Long.MAX_VALUE : estimateSize).setCharacteristics(Spliterator.CONCURRENT | Spliterator.DISTINCT | Spliterator.NONNULL).get(); } @Override public int size(){ long size=stream().count(); if (size > Integer.MAX_VALUE) { return Integer.MAX_VALUE; } return (int)size; } } to new AbstractDelegatingKeyCacheSet(Caches.getCacheWithFlags(cache,command),set){ @Override public CloseableIterator<K> iterator(){ return new TransactionAwareKeyCloseableIterator<>(super.iterator(),(TxInvocationContext<LocalTransaction>)ctx,cache); } @Override public CloseableSpliterator<K> spliterator(){ Spliterator<K> parentSpliterator=super.spliterator(); long estimateSize=parentSpliterator.estimateSize() + ctx.getLookedUpEntries().size(); return new IteratorAsSpliterator.Builder<>(iterator()).setEstimateRemaining(estimateSize < 0L ? Long.MAX_VALUE : estimateSize).setCharacteristics(Spliterator.CONCURRENT | Spliterator.DISTINCT | Spliterator.NONNULL).get(); } @Override public int size(){ long size=stream().count(); if (size > Integer.MAX_VALUE) { return Integer.MAX_VALUE; } return (int)size; } }
- set to set
- keySet to keySet
- new AbstractDelegatingEntryCacheSet<K,V>(Caches.getCacheWithFlags(cache,command),set){ @Override public CloseableIterator<CacheEntry<K,V>> iterator(){ return new CloseableIteratorMapper<>(super.iterator(),e -> unwrapEntry(e,null)); } @Override public CloseableSpliterator<CacheEntry<K,V>> spliterator(){ return new IteratorAsSpliterator.Builder<>(iterator()).setEstimateRemaining(super.spliterator().estimateSize()).setCharacteristics(Spliterator.CONCURRENT | Spliterator.DISTINCT | Spliterator.NONNULL).get(); } } to new AbstractDelegatingEntryCacheSet<K,V>(Caches.getCacheWithFlags(cache,command),set){ @Override public CloseableIterator<CacheEntry<K,V>> iterator(){ return new CloseableIteratorMapper<>(super.iterator(),e -> unwrapEntry(e,null)); } @Override public CloseableSpliterator<CacheEntry<K,V>> spliterator(){ return new IteratorAsSpliterator.Builder<>(iterator()).setEstimateRemaining(super.spliterator().estimateSize()).setCharacteristics(Spliterator.CONCURRENT | Spliterator.DISTINCT | Spliterator.NONNULL).get(); } }
- new AbstractDelegatingKeyCacheSet<K,V>(Caches.getCacheWithFlags(cache,command),set){ @Override public CloseableIterator<K> iterator(){ return new CloseableIteratorMapper<>(super.iterator(),e -> processRetVal(e,null)); } @Override public CloseableSpliterator<K> spliterator(){ return new IteratorAsSpliterator.Builder<>(iterator()).setEstimateRemaining(super.spliterator().estimateSize()).setCharacteristics(Spliterator.CONCURRENT | Spliterator.DISTINCT | Spliterator.NONNULL).get(); } } to new AbstractDelegatingKeyCacheSet<K,V>(Caches.getCacheWithFlags(cache,command),set){ @Override public CloseableIterator<K> iterator(){ return new CloseableIteratorMapper<>(super.iterator(),e -> processRetVal(e,null)); } @Override public CloseableSpliterator<K> spliterator(){ return new IteratorAsSpliterator.Builder<>(iterator()).setEstimateRemaining(super.spliterator().estimateSize()).setCharacteristics(Spliterator.CONCURRENT | Spliterator.DISTINCT | Spliterator.NONNULL).get(); } }
- new AbstractDelegatingEntryCacheSet<K,V>(Caches.getCacheWithFlags(cache,command),set){ @Override public CloseableIterator<CacheEntry<K,V>> iterator(){ return new TypeConverterIterator<>(super.iterator(),converter,entryFactory); } @Override public CloseableSpliterator<CacheEntry<K,V>> spliterator(){ return new IteratorAsSpliterator.Builder<>(iterator()).setEstimateRemaining(super.spliterator().estimateSize()).setCharacteristics(Spliterator.CONCURRENT | Spliterator.DISTINCT | Spliterator.NONNULL).get(); } protected CacheStream<CacheEntry<K,V>> getStream( boolean parallel){ DistributionManager dm=cache.getAdvancedCache().getDistributionManager(); CloseableSpliterator<CacheEntry<K,V>> closeableSpliterator=super.spliterator(); CacheStream<CacheEntry<K,V>> stream=new LocalCacheStream<>(new EntryStreamSupplier<>(cache,dm != null ? dm.getConsistentHash() : null,() -> StreamSupport.stream(closeableSpliterator,parallel)),parallel,cache.getAdvancedCache().getComponentRegistry()); stream.onClose(closeableSpliterator::close); return new TypeConverterStream(stream,converter,entryFactory); } } to new AbstractDelegatingEntryCacheSet<K,V>(Caches.getCacheWithFlags(cache,command),set){ @Override public CloseableIterator<CacheEntry<K,V>> iterator(){ return new TypeConverterIterator<>(super.iterator(),converter,entryFactory); } @Override public CloseableSpliterator<CacheEntry<K,V>> spliterator(){ return new IteratorAsSpliterator.Builder<>(iterator()).setEstimateRemaining(super.spliterator().estimateSize()).setCharacteristics(Spliterator.CONCURRENT | Spliterator.DISTINCT | Spliterator.NONNULL).get(); } protected CacheStream<CacheEntry<K,V>> getStream( boolean parallel){ DistributionManager dm=cache.getAdvancedCache().getDistributionManager(); CloseableSpliterator<CacheEntry<K,V>> closeableSpliterator=super.spliterator(); CacheStream<CacheEntry<K,V>> stream=new LocalCacheStream<>(new EntryStreamSupplier<>(cache,dm != null ? dm.getConsistentHash() : null,() -> StreamSupport.stream(closeableSpliterator,parallel)),parallel,cache.getAdvancedCache().getComponentRegistry()); stream.onClose(closeableSpliterator::close); return new TypeConverterStream(stream,converter,entryFactory); } }
- entrySet to entrySet
- new AbstractDelegatingKeyCacheSet<K,V>(Caches.getCacheWithFlags(cache,command),set){ @Override public CloseableIterator<K> iterator(){ return new CloseableIteratorMapper<>(super.iterator(),k -> (K)converter.unboxKey(k)); } @Override public CloseableSpliterator<K> spliterator(){ return new IteratorAsSpliterator.Builder<>(iterator()).setEstimateRemaining(super.spliterator().estimateSize()).setCharacteristics(Spliterator.CONCURRENT | Spliterator.DISTINCT | Spliterator.NONNULL).get(); } protected CacheStream<K> getStream( boolean parallel){ DistributionManager dm=cache.getAdvancedCache().getDistributionManager(); CloseableSpliterator<K> closeableSpliterator=super.spliterator(); CacheStream<K> stream=new LocalCacheStream<>(new KeyStreamSupplier<>(cache,dm != null ? dm.getConsistentHash() : null,() -> StreamSupport.stream(closeableSpliterator,parallel)),parallel,cache.getAdvancedCache().getComponentRegistry()); stream.onClose(closeableSpliterator::close); return new TypeConverterStream(stream,converter,entryFactory); } } to new AbstractDelegatingKeyCacheSet<K,V>(Caches.getCacheWithFlags(cache,command),set){ @Override public CloseableIterator<K> iterator(){ return new CloseableIteratorMapper<>(super.iterator(),k -> (K)converter.unboxKey(k)); } @Override public CloseableSpliterator<K> spliterator(){ return new IteratorAsSpliterator.Builder<>(iterator()).setEstimateRemaining(super.spliterator().estimateSize()).setCharacteristics(Spliterator.CONCURRENT | Spliterator.DISTINCT | Spliterator.NONNULL).get(); } protected CacheStream<K> getStream( boolean parallel){ DistributionManager dm=cache.getAdvancedCache().getDistributionManager(); CloseableSpliterator<K> closeableSpliterator=super.spliterator(); CacheStream<K> stream=new LocalCacheStream<>(new KeyStreamSupplier<>(cache,dm != null ? dm.getConsistentHash() : null,() -> StreamSupport.stream(closeableSpliterator,parallel)),parallel,cache.getAdvancedCache().getComponentRegistry()); stream.onClose(closeableSpliterator::close); return new TypeConverterStream(stream,converter,entryFactory); } }
- new AbstractDelegatingEntryCacheSet<K,V>(Caches.getCacheWithFlags(cache,command),set){ @Override public CloseableIterator<CacheEntry<K,V>> iterator(){ return new TransactionAwareEntryCloseableIterator<>(super.iterator(),(TxInvocationContext<LocalTransaction>)ctx,cache); } @Override public CloseableSpliterator<CacheEntry<K,V>> spliterator(){ Spliterator<CacheEntry<K,V>> parentSpliterator=super.spliterator(); long estimateSize=parentSpliterator.estimateSize() + ctx.getLookedUpEntries().size(); return new IteratorAsSpliterator.Builder<>(iterator()).setEstimateRemaining(estimateSize < 0L ? Long.MAX_VALUE : estimateSize).setCharacteristics(Spliterator.CONCURRENT | Spliterator.DISTINCT | Spliterator.NONNULL).get(); } @Override public int size(){ long size=stream().count(); if (size > Integer.MAX_VALUE) { return Integer.MAX_VALUE; } return (int)size; } } to new AbstractDelegatingEntryCacheSet<K,V>(Caches.getCacheWithFlags(cache,command),set){ @Override public CloseableIterator<CacheEntry<K,V>> iterator(){ return new TransactionAwareEntryCloseableIterator<>(super.iterator(),(TxInvocationContext<LocalTransaction>)ctx,cache); } @Override public CloseableSpliterator<CacheEntry<K,V>> spliterator(){ Spliterator<CacheEntry<K,V>> parentSpliterator=super.spliterator(); long estimateSize=parentSpliterator.estimateSize() + ctx.getLookedUpEntries().size(); return new IteratorAsSpliterator.Builder<>(iterator()).setEstimateRemaining(estimateSize < 0L ? Long.MAX_VALUE : estimateSize).setCharacteristics(Spliterator.CONCURRENT | Spliterator.DISTINCT | Spliterator.NONNULL).get(); } @Override public int size(){ long size=stream().count(); if (size > Integer.MAX_VALUE) { return Integer.MAX_VALUE; } return (int)size; } }
- set to set
- entrySet to entrySet