org.infinispan.interceptors.BasicInvocationStage to java.lang.Object
No. of Instances - 453
No. of Commits - 1
No. of Projects - {'infinispan'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
- Update argument list (Method invocation)
- retryWhenDone to retryWhenDone
- retryWhenDone to retryWhenDone
- retryWhenDone to retryWhenDone
- retryWhenDone to retryWhenDone
- retryWhenDone to retryWhenDone
- Other
- UnsureResponse.INSTANCE to UnsureResponse.INSTANCE
- null to null
- UnsureResponse.INSTANCE to UnsureResponse.INSTANCE
- null to null
- null to null
- command.perform(ctx) to command.perform(ctx)
- null to null
- Stream.empty() to Stream.empty()
- localResult to localResult
- localResult to localResult
- false to false
- true to true
- localLockCommandWork(ctx,command) to localLockCommandWork(ctx,command)
- null to null
- UnsuccessfulResponse.INSTANCE to UnsuccessfulResponse.INSTANCE
- returnValue to returnValue
- null to null
- null to null
- null to null
- null to null
- null to null
- null to null
- keySet to keySet
- returnValue to returnValue
- Rename Variable
- Update Anonymous class
- { @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(); } @Override 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 { @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(); } @Override 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); } }
- { @Override public CloseableIterator<CacheEntry<K,V>> iterator(){ return new TransactionAwareEntryCloseableIterator<>(super.iterator(),(TxInvocationContext<LocalTransaction>)rCtx,cache); } @Override public CloseableSpliterator<CacheEntry<K,V>> spliterator(){ Spliterator<CacheEntry<K,V>> parentSpliterator=super.spliterator(); long estimateSize=parentSpliterator.estimateSize() + rCtx.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 { @Override public CloseableIterator<CacheEntry<K,V>> iterator(){ return new TransactionAwareEntryCloseableIterator<>(super.iterator(),(TxInvocationContext<LocalTransaction>)rCtx,cache); } @Override public CloseableSpliterator<CacheEntry<K,V>> spliterator(){ Spliterator<CacheEntry<K,V>> parentSpliterator=super.spliterator(); long estimateSize=parentSpliterator.estimateSize() + rCtx.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; } }
- { @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(); } @Override 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 { @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(); } @Override 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); } }
- { @Override public CloseableIterator<K> iterator(){ return new TransactionAwareKeyCloseableIterator<>(super.iterator(),(TxInvocationContext<LocalTransaction>)rCtx,cache); } @Override public CloseableSpliterator<K> spliterator(){ Spliterator<K> parentSpliterator=super.spliterator(); long estimateSize=parentSpliterator.estimateSize() + rCtx.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 { @Override public CloseableIterator<K> iterator(){ return new TransactionAwareKeyCloseableIterator<>(super.iterator(),(TxInvocationContext<LocalTransaction>)rCtx,cache); } @Override public CloseableSpliterator<K> spliterator(){ Spliterator<K> parentSpliterator=super.spliterator(); long estimateSize=parentSpliterator.estimateSize() + rCtx.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; } }