|
Change Parameter Type streamSupplier : Supplier<Stream<CacheEntry<K,V>>> to streamSupplier : Supplier<Stream<Original>> in method public start(origin Address, streamSupplier Supplier<Stream<Original>>, intOps Iterable<IntermediateOperation>, requestId Object) : OnCloseIterator<E> in class org.infinispan.stream.impl.IteratorHandler |
From |
To |
|
Change Parameter Type supplier : Supplier<? extends Stream<?>> to supplier : Supplier<Stream<Original>> in method public setSupplier(supplier Supplier<Stream<Original>>) : void in class org.infinispan.stream.impl.KeyTrackingTerminalOperation |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public ForEachObjLongOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int, consumer ObjLongConsumer<Cache<K,?>>) in class org.infinispan.stream.impl.termop.primitive.ForEachObjLongOperation |
From |
To |
|
Change Parameter Type cacheEntrySet : CacheSet<CacheEntry<K,V>> to cacheEntrySet : CacheSet<Original> in method private getRehashStream(cacheEntrySet CacheSet<Original>, requestId Object, listener SegmentListener, parallelStream boolean, entryStream boolean, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Set<K>) : Stream<Original> in class org.infinispan.stream.impl.LocalStreamManagerImpl |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public ForEachFlatMapLongOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int, consumer LongConsumer) in class org.infinispan.stream.impl.termop.primitive.ForEachFlatMapLongOperation |
From |
To |
|
Change Parameter Type operation : KeyTrackingTerminalOperation<K,?,R2> to operation : KeyTrackingTerminalOperation<Original,K,?> in method public remoteStreamOperationRehashAware(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,?>, callback ResultsCallback<Collection<K>>) : Object in class org.infinispan.stream.impl.PartitionAwareClusterStreamManager |
From |
To |
|
Change Parameter Type operation : TerminalOperation<R> to operation : TerminalOperation<Original,R> in method public remoteStreamOperationRehashAware(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation TerminalOperation<Original,R>, callback ResultsCallback<R>, earlyTerminatePredicate Predicate<? super R>) : Object in class org.infinispan.stream.impl.ClusterStreamManager |
From |
To |
|
Change Parameter Type callback : ResultsCallback<Map<K,R2>> to callback : ResultsCallback<Collection<K>> in method public remoteStreamOperationRehashAware(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,?>, callback ResultsCallback<Collection<K>>) : Object in class org.infinispan.stream.impl.ClusterStreamManager |
From |
To |
|
Change Parameter Type entrySet : CacheSet<CacheEntry<K,V>> to keySet : CacheSet<K> in method public TxBackingKeySet(cache Cache<K,V>, keySet CacheSet<K>, command FlagAffectedCommand, ctx LocalTxInvocationContext) in class org.infinispan.interceptors.distribution.DistributionBulkInterceptor.TxBackingKeySet |
From |
To |
|
Change Parameter Type operation : KeyTrackingTerminalOperation<K,R,?> to operation : KeyTrackingTerminalOperation<Original,K,R> in method public remoteStreamOperation(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,R>, callback ResultsCallback<Collection<R>>) : Object in class org.infinispan.stream.impl.ClusterStreamManager |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public AbstractForEachLongOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int) in class org.infinispan.stream.impl.termop.primitive.AbstractForEachLongOperation |
From |
To |
|
Change Parameter Type operation : KeyTrackingTerminalOperation<K,?,R2> to operation : KeyTrackingTerminalOperation<Original,K,?> in method public streamOperationRehashAware(requestId Object, origin Address, parallelStream boolean, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Set<K>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,?>) : void in class org.infinispan.stream.impl.LocalStreamManager |
From |
To |
|
Change Parameter Type response : IntermediateCollector<Collection<CacheEntry<K,K>>> to response : IntermediateCollector<Collection<K>> in method public performForEachOperation(response IntermediateCollector<Collection<K>>) : Collection<K> in class org.infinispan.stream.impl.termop.AbstractForEachOperation |
From |
To |
|
Change Parameter Type entrySet : Set<CacheEntry<K,V>> to entrySet : CacheSet<CacheEntry<K,V>> in method public BackingEntrySet(ignoreOwnership boolean, entrySet CacheSet<CacheEntry<K,V>>) in class org.infinispan.interceptors.impl.PrefetchInterceptor.BackingEntrySet |
From |
To |
|
Change Parameter Type operation : TerminalOperation<R> to operation : TerminalOperation<Original,R> in method public streamOperation(requestId Object, origin Address, parallelStream boolean, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Set<K>, includeLoader boolean, entryStream boolean, operation TerminalOperation<Original,R>) : void in class org.infinispan.stream.impl.LocalStreamManagerImpl |
From |
To |
|
Change Parameter Type function : Function<Supplier<Stream<CacheEntry>>,KeyTrackingTerminalOperation<Object,? extends T,Object>> to function : Function<Supplier<Stream<Original>>,KeyTrackingTerminalOperation<Original,Object,? extends T>> in method package performRehashKeyTrackingOperation(function Function<Supplier<Stream<Original>>,KeyTrackingTerminalOperation<Original,Object,? extends T>>) : void in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Parameter Type supplier : Supplier<CacheStream<CacheEntry<K,V>>> to supplier : Supplier<CacheStream<R>> in method public DistributedCacheStream(localAddress Address, parallel boolean, dm DistributionManager, supplier Supplier<CacheStream<R>>, csm ClusterStreamManager, includeLoader boolean, distributedBatchSize int, executor Executor, registry ComponentRegistry, toKeyFunction Function<? super Original,?>) in class org.infinispan.stream.impl.DistributedCacheStream |
From |
To |
|
Change Parameter Type supplier : Supplier<? extends Stream<?>> to supplier : Supplier<Stream<Original>> in method public setSupplier(supplier Supplier<Stream<Original>>) : void in class org.infinispan.stream.impl.termop.BaseTerminalOperation |
From |
To |
|
Change Parameter Type operation : KeyTrackingTerminalOperation<K,?,R2> to operation : KeyTrackingTerminalOperation<Original,K,?> in method public streamOperationRehashAware(requestId Object, origin Address, parallelStream boolean, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Set<K>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,?>) : void in class org.infinispan.stream.impl.LocalStreamManagerImpl |
From |
To |
|
Change Parameter Type other : AbstractCacheStream<T,S,S2> to other : AbstractCacheStream<Original,T,S,S2> in method protected AbstractCacheStream(other AbstractCacheStream<Original,T,S,S2>) in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public ForEachFlatMapObjLongOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int, consumer ObjLongConsumer<Cache<K,?>>) in class org.infinispan.stream.impl.termop.primitive.ForEachFlatMapObjLongOperation |
From |
To |
|
Change Parameter Type operation : TerminalOperation<R> to operation : TerminalOperation<Original,R> in method public streamOperationRehashAware(requestId Object, origin Address, parallelStream boolean, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Set<K>, includeLoader boolean, entryStream boolean, operation TerminalOperation<Original,R>) : void in class org.infinispan.stream.impl.LocalStreamManager |
From |
To |
|
Change Parameter Type operation : TerminalOperation<R> to operation : TerminalOperation<Original,R> in method public remoteStreamOperationRehashAware(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation TerminalOperation<Original,R>, callback ResultsCallback<R>, earlyTerminatePredicate Predicate<? super R>) : Object in class org.infinispan.stream.impl.ClusterStreamManagerImpl |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public AbstractForEachOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int) in class org.infinispan.stream.impl.termop.AbstractForEachOperation |
From |
To |
|
Change Parameter Type keySet : Set<K> to keySet : CacheSet<K> in method public BackingKeySet(ignoreOwnership boolean, keySet CacheSet<K>) in class org.infinispan.interceptors.impl.PrefetchInterceptor.BackingKeySet |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method package getForEach(consumer IntConsumer, supplier Supplier<Stream<Original>>) : KeyTrackingTerminalOperation<Original,Object,Integer> in class org.infinispan.stream.impl.DistributedIntCacheStream |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public ForEachBiOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int, consumer BiConsumer<Cache<K,?>,? super V>) in class org.infinispan.stream.impl.termop.object.ForEachBiOperation |
From |
To |
|
Change Parameter Type cacheEntrySet : CacheSet<CacheEntry<K,V>> to cacheEntrySet : CacheSet<Original> in method private getStream(cacheEntrySet CacheSet<Original>, parallelStream boolean, entryStream boolean, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Set<K>) : Stream<Original> in class org.infinispan.stream.impl.LocalStreamManagerImpl |
From |
To |
|
Change Parameter Type operation : TerminalOperation<R> to operation : TerminalOperation<Original,R> in method public remoteStreamOperation(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation TerminalOperation<Original,R>, callback ResultsCallback<R>, earlyTerminatePredicate Predicate<? super R>) : Object in class org.infinispan.stream.impl.ClusterStreamManagerImpl |
From |
To |
|
Change Parameter Type operation : TerminalOperation<R> to operation : TerminalOperation<Original,R> in method public remoteStreamOperation(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation TerminalOperation<Original,R>, callback ResultsCallback<R>, earlyTerminatePredicate Predicate<? super R>) : Object in class org.infinispan.stream.impl.tx.TxClusterStreamManager |
From |
To |
|
Change Parameter Type csm : ClusterStreamManager<Object> to csm : ClusterStreamManager<Original,Object> in method protected AbstractCacheStream(localAddress Address, parallel boolean, dm DistributionManager, supplier Supplier<CacheStream<Original>>, csm ClusterStreamManager<Original,Object>, includeLoader boolean, distributedBatchSize int, executor Executor, registry ComponentRegistry, toKeyFunction Function<? super Original,?>) in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method package getForEach(consumer DoubleConsumer, supplier Supplier<Stream<Original>>) : KeyTrackingTerminalOperation<Original,Object,Double> in class org.infinispan.stream.impl.DistributedDoubleCacheStream |
From |
To |
|
Change Parameter Type operation : KeyTrackingTerminalOperation<K,?,R2> to operation : KeyTrackingTerminalOperation<Original,K,?> in method public remoteStreamOperationRehashAware(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,?>, callback ResultsCallback<Collection<K>>) : Object in class org.infinispan.stream.impl.tx.TxClusterStreamManager |
From |
To |
|
Change Parameter Type supplier : Supplier<? extends Stream<?>> to supplier : Supplier<Stream<Original>> in method public setSupplier(supplier Supplier<Stream<Original>>) : void in class org.infinispan.stream.impl.TerminalOperation |
From |
To |
|
Change Parameter Type supplier : Supplier<CacheStream<CacheEntry>> to supplier : Supplier<CacheStream<Original>> in method protected AbstractCacheStream(localAddress Address, parallel boolean, dm DistributionManager, supplier Supplier<CacheStream<Original>>, csm ClusterStreamManager<Original,Object>, includeLoader boolean, distributedBatchSize int, executor Executor, registry ComponentRegistry, toKeyFunction Function<? super Original,?>) in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public ForEachFlatMapObjDoubleOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int, consumer ObjDoubleConsumer<Cache<K,?>>) in class org.infinispan.stream.impl.termop.primitive.ForEachFlatMapObjDoubleOperation |
From |
To |
|
Change Parameter Type entrySet : CacheSet<CacheEntry<K,V>> to keySet : CacheSet<K> in method public BackingKeySet(cache Cache<K,V>, keySet CacheSet<K>, command FlagAffectedCommand) in class org.infinispan.interceptors.distribution.DistributionBulkInterceptor.BackingKeySet |
From |
To |
|
Change Parameter Type cacheEntryStream : Stream<CacheEntry> to cacheEntryStream : Stream<Object> in method public perform(cacheEntryStream Stream<Object>) : OutputStream in class org.infinispan.stream.impl.AbstractCacheStream.FlatMapHandler |
From |
To |
|
Change Parameter Type response : IntermediateCollector<Collection<CacheEntry<K,K>>> to response : IntermediateCollector<Collection<K>> in method public performForEachOperation(response IntermediateCollector<Collection<K>>) : Collection<K> in class org.infinispan.stream.impl.termop.primitive.AbstractForEachLongOperation |
From |
To |
|
Change Parameter Type callback : ResultsCallback<Map<K,R2>> to callback : ResultsCallback<Collection<K>> in method public remoteStreamOperationRehashAware(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,?>, callback ResultsCallback<Collection<K>>) : Object in class org.infinispan.stream.impl.tx.TxClusterStreamManager |
From |
To |
|
Change Parameter Type csm : TxClusterStreamManager<?> to csm : TxClusterStreamManager<Original,K> in method public TxDistributedCacheStream(localAddress Address, parallel boolean, dm DistributionManager, supplier Supplier<CacheStream<R>>, csm TxClusterStreamManager<Original,K>, includeLoader boolean, distributedBatchSize int, executor Executor, registry ComponentRegistry, ctx LocalTxInvocationContext, toKeyFunction Function<? super Original,?>, toOriginalFunction Function<? super CacheEntry<K,V>,? extends Original>) in class org.infinispan.stream.impl.tx.TxDistributedCacheStream |
From |
To |
|
Change Parameter Type operation : KeyTrackingTerminalOperation<K,R,?> to operation : KeyTrackingTerminalOperation<Original,K,R> in method public streamOperation(requestId Object, origin Address, parallelStream boolean, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Set<K>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,R>) : void in class org.infinispan.stream.impl.LocalStreamManager |
From |
To |
|
Change Parameter Type supplier : Supplier<? extends Stream<?>> to supplier : Supplier<Stream<Original>> in method public SegmentRetryingOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, function Function<? super S2,? extends E>) in class org.infinispan.stream.impl.termop.SegmentRetryingOperation |
From |
To |
|
Change Parameter Type supplier : Supplier<CacheStream<CacheEntry<K,V>>> to supplier : Supplier<CacheStream<R>> in method public TxDistributedCacheStream(localAddress Address, parallel boolean, dm DistributionManager, supplier Supplier<CacheStream<R>>, csm TxClusterStreamManager<Original,K>, includeLoader boolean, distributedBatchSize int, executor Executor, registry ComponentRegistry, ctx LocalTxInvocationContext, toKeyFunction Function<? super Original,?>, toOriginalFunction Function<? super CacheEntry<K,V>,? extends Original>) in class org.infinispan.stream.impl.tx.TxDistributedCacheStream |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method package getForEach(consumer ObjLongConsumer<Cache<K,V>>, supplier Supplier<Stream<Original>>) : KeyTrackingTerminalOperation<Original,Object,Long> in class org.infinispan.stream.impl.DistributedLongCacheStream |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public ForEachLongOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int, consumer LongConsumer) in class org.infinispan.stream.impl.termop.primitive.ForEachLongOperation |
From |
To |
|
Change Parameter Type remoteStream : DistributedCacheStream<R> to remoteStream : DistributedCacheStream<Original,R> in method public IntermediateCacheStream(remoteStream DistributedCacheStream<Original,R>) in class org.infinispan.stream.impl.IntermediateCacheStream |
From |
To |
|
Change Parameter Type supplier : Supplier<? extends BaseStream<?,?>> to supplier : Supplier<Stream<Original>> in method protected BaseTerminalOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>) in class org.infinispan.stream.impl.termop.BaseTerminalOperation |
From |
To |
|
Change Parameter Type operation : TerminalOperation<R> to operation : TerminalOperation<Original,R> in method public remoteStreamOperationRehashAware(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation TerminalOperation<Original,R>, callback ResultsCallback<R>, earlyTerminatePredicate Predicate<? super R>) : Object in class org.infinispan.stream.impl.PartitionAwareClusterStreamManager |
From |
To |
|
Change Parameter Type operation : KeyTrackingTerminalOperation<K,R,?> to operation : KeyTrackingTerminalOperation<Original,K,R> in method public remoteStreamOperation(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,R>, callback ResultsCallback<Collection<R>>) : Object in class org.infinispan.stream.impl.ClusterStreamManagerImpl |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public ForEachObjIntOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int, consumer ObjIntConsumer<Cache<K,?>>) in class org.infinispan.stream.impl.termop.primitive.ForEachObjIntOperation |
From |
To |
|
Change Parameter Type response : IntermediateCollector<Collection<CacheEntry<K,K>>> to response : IntermediateCollector<Collection<K>> in method public performForEachOperation(response IntermediateCollector<Collection<K>>) : Collection<K> in class org.infinispan.stream.impl.termop.primitive.AbstractForEachIntOperation |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method package getForEach(consumer ObjDoubleConsumer<Cache<K,V>>, supplier Supplier<Stream<Original>>) : KeyTrackingTerminalOperation<Original,Object,Double> in class org.infinispan.stream.impl.DistributedDoubleCacheStream |
From |
To |
|
Change Parameter Type supplier : Supplier<? extends BaseStream<?,?>> to supplier : Supplier<Stream<Original>> in method public SingleRunOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, function Function<? super S2,? extends E>) in class org.infinispan.stream.impl.termop.SingleRunOperation |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public AbstractForEachIntOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int) in class org.infinispan.stream.impl.termop.primitive.AbstractForEachIntOperation |
From |
To |
|
Change Parameter Type operation : KeyTrackingTerminalOperation<K,?,R2> to operation : KeyTrackingTerminalOperation<Original,K,?> in method public remoteStreamOperationRehashAware(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,?>, callback ResultsCallback<Collection<K>>) : Object in class org.infinispan.stream.impl.ClusterStreamManager |
From |
To |
|
Change Parameter Type operation : KeyTrackingTerminalOperation<K,R,?> to operation : KeyTrackingTerminalOperation<Original,K,R> in method public remoteStreamOperation(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,R>, callback ResultsCallback<Collection<R>>) : Object in class org.infinispan.stream.impl.PartitionAwareClusterStreamManager |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public ForEachOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int, consumer Consumer<? super V>) in class org.infinispan.stream.impl.termop.object.ForEachOperation |
From |
To |
|
Change Parameter Type response : IntermediateCollector<Collection<CacheEntry<K,K>>> to response : IntermediateCollector<Collection<K>> in method public performForEachOperation(response IntermediateCollector<Collection<K>>) : Collection<K> in class org.infinispan.stream.impl.termop.primitive.AbstractForEachDoubleOperation |
From |
To |
|
Change Parameter Type operation : TerminalOperation<R> to operation : TerminalOperation<Original,R> in method public streamOperation(requestId Object, origin Address, parallelStream boolean, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Set<K>, includeLoader boolean, entryStream boolean, operation TerminalOperation<Original,R>) : void in class org.infinispan.stream.impl.LocalStreamManager |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method package getForEach(consumer LongConsumer, supplier Supplier<Stream<Original>>) : KeyTrackingTerminalOperation<Original,Object,Long> in class org.infinispan.stream.impl.DistributedLongCacheStream |
From |
To |
|
Change Parameter Type operation : KeyTrackingTerminalOperation<K,?,R2> to operation : KeyTrackingTerminalOperation<Original,K,?> in method public remoteStreamOperationRehashAware(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,?>, callback ResultsCallback<Collection<K>>) : Object in class org.infinispan.stream.impl.ClusterStreamManagerImpl |
From |
To |
|
Change Parameter Type callback : ResultsCallback<Map<K,R2>> to callback : ResultsCallback<Collection<K>> in method public remoteStreamOperationRehashAware(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,?>, callback ResultsCallback<Collection<K>>) : Object in class org.infinispan.stream.impl.ClusterStreamManagerImpl |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public ForEachFlatMapIntOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int, consumer IntConsumer) in class org.infinispan.stream.impl.termop.primitive.ForEachFlatMapIntOperation |
From |
To |
|
Change Parameter Type results : Collection<CacheEntry<K,Object>> to results : Collection<K> in method public onCompletion(address Address, completedSegments Set<Integer>, results Collection<K>) : void in class org.infinispan.stream.impl.AbstractCacheStream.KeyTrackingConsumer |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method package getForEach(consumer ObjIntConsumer<Cache<K,V>>, supplier Supplier<Stream<Original>>) : KeyTrackingTerminalOperation<Original,Object,Integer> in class org.infinispan.stream.impl.DistributedIntCacheStream |
From |
To |
|
Change Parameter Type operation : TerminalOperation<R> to operation : TerminalOperation<Original,R> in method public streamOperationRehashAware(requestId Object, origin Address, parallelStream boolean, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Set<K>, includeLoader boolean, entryStream boolean, operation TerminalOperation<Original,R>) : void in class org.infinispan.stream.impl.LocalStreamManagerImpl |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public ForEachFlatMapObjIntOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int, consumer ObjIntConsumer<Cache<K,?>>) in class org.infinispan.stream.impl.termop.primitive.ForEachFlatMapObjIntOperation |
From |
To |
|
Change Parameter Type operation : TerminalOperation<R> to operation : TerminalOperation<Original,R> in method public remoteStreamOperation(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation TerminalOperation<Original,R>, callback ResultsCallback<R>, earlyTerminatePredicate Predicate<? super R>) : Object in class org.infinispan.stream.impl.ClusterStreamManager |
From |
To |
|
Change Parameter Type response : Collection<CacheEntry<K,Object>> to response : Collection<K> in method public sendDataResonse(response Collection<K>) : void in class org.infinispan.stream.impl.AbstractCacheStream.KeyTrackingConsumer |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public ForEachFlatMapDoubleOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int, consumer DoubleConsumer) in class org.infinispan.stream.impl.termop.primitive.ForEachFlatMapDoubleOperation |
From |
To |
|
Change Parameter Type manager : ClusterStreamManager<K> to manager : ClusterStreamManager<Original,K> in method public TxClusterStreamManager(manager ClusterStreamManager<Original,K>, ctx LocalTxInvocationContext, maxSegments int, intFunction ToIntFunction<Object>) in class org.infinispan.stream.impl.tx.TxClusterStreamManager |
From |
To |
|
Change Parameter Type operation : TerminalOperation<R> to operation : TerminalOperation<Original,R> in method public remoteStreamOperationRehashAware(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation TerminalOperation<Original,R>, callback ResultsCallback<R>, earlyTerminatePredicate Predicate<? super R>) : Object in class org.infinispan.stream.impl.tx.TxClusterStreamManager |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public ForEachIntOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int, consumer IntConsumer) in class org.infinispan.stream.impl.termop.primitive.ForEachIntOperation |
From |
To |
|
Change Parameter Type results : Collection<CacheEntry<K,Object>> to results : Collection<K> in method public onIntermediateResult(address Address, results Collection<K>) : Set<Integer> in class org.infinispan.stream.impl.AbstractCacheStream.KeyTrackingConsumer |
From |
To |
|
Change Parameter Type callback : ResultsCallback<Map<K,R2>> to callback : ResultsCallback<Collection<K>> in method public remoteStreamOperationRehashAware(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,?>, callback ResultsCallback<Collection<K>>) : Object in class org.infinispan.stream.impl.PartitionAwareClusterStreamManager |
From |
To |
|
Change Parameter Type operation : TerminalOperation<R> to operation : TerminalOperation<Original,R> in method public remoteStreamOperation(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation TerminalOperation<Original,R>, callback ResultsCallback<R>, earlyTerminatePredicate Predicate<? super R>) : Object in class org.infinispan.stream.impl.PartitionAwareClusterStreamManager |
From |
To |
|
Change Parameter Type cacheEntryStream : Stream<CacheEntry> to cacheEntryStream : Stream<Object> in method public perform(cacheEntryStream Stream<Object>) : OutputStream in class org.infinispan.stream.impl.AbstractCacheStream.MapHandler |
From |
To |
|
Change Parameter Type operation : KeyTrackingTerminalOperation<K,R,?> to operation : KeyTrackingTerminalOperation<Original,K,R> in method public remoteStreamOperation(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,R>, callback ResultsCallback<Collection<R>>) : Object in class org.infinispan.stream.impl.tx.TxClusterStreamManager |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public ForEachDoubleOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int, consumer DoubleConsumer) in class org.infinispan.stream.impl.termop.primitive.ForEachDoubleOperation |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public ForEachObjDoubleOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int, consumer ObjDoubleConsumer<Cache<K,?>>) in class org.infinispan.stream.impl.termop.primitive.ForEachObjDoubleOperation |
From |
To |
|
Change Parameter Type operation : KeyTrackingTerminalOperation<K,R,?> to operation : KeyTrackingTerminalOperation<Original,K,R> in method public streamOperation(requestId Object, origin Address, parallelStream boolean, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Set<K>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,R>) : void in class org.infinispan.stream.impl.LocalStreamManagerImpl |
From |
To |
|
Change Parameter Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method public AbstractForEachDoubleOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<Stream<Original>>, toKeyFunction Function<? super Original,? extends K>, batchSize int) in class org.infinispan.stream.impl.termop.primitive.AbstractForEachDoubleOperation |
From |
To |
|
Change Return Type Supplier<Stream<CacheEntry>> to Supplier<Stream<Original>> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedLongCacheStream |
From |
To |
|
Change Return Type DistributedDoubleCacheStream to DistributedDoubleCacheStream<Original> in method protected doubleCacheStream() : DistributedDoubleCacheStream<Original> in class org.infinispan.stream.impl.tx.TxDistributedCacheStream |
From |
To |
|
Change Return Type DistributedCacheStream<R> to DistributedCacheStream<Original,R> in method protected cacheStream() : DistributedCacheStream<Original,R> in class org.infinispan.stream.impl.tx.TxDistributedLongCacheStream |
From |
To |
|
Change Return Type Collection<CacheEntry<K,K>> to Collection<K> in method public performForEachOperation(response IntermediateCollector<Collection<K>>) : Collection<K> in class org.infinispan.stream.impl.termop.primitive.AbstractForEachDoubleOperation |
From |
To |
|
Change Return Type DistributedCacheStream<R> to DistributedCacheStream<Original,R> in method protected cacheStream() : DistributedCacheStream<Original,R> in class org.infinispan.stream.impl.DistributedDoubleCacheStream |
From |
To |
|
Change Return Type KeyTrackingTerminalOperation<Object,Double,Object> to KeyTrackingTerminalOperation<Original,Object,Double> in method package getForEach(consumer DoubleConsumer, supplier Supplier<Stream<Original>>) : KeyTrackingTerminalOperation<Original,Object,Double> in class org.infinispan.stream.impl.DistributedDoubleCacheStream |
From |
To |
|
Change Return Type DistributedLongCacheStream to DistributedLongCacheStream<Original> in method protected longCacheStream() : DistributedLongCacheStream<Original> in class org.infinispan.stream.impl.DistributedIntCacheStream |
From |
To |
|
Change Return Type Supplier<Stream<CacheEntry>> to Supplier<Stream<Original>> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedDoubleCacheStream |
From |
To |
|
Change Return Type DistributedDoubleCacheStream to DistributedDoubleCacheStream<Original> in method protected doubleCacheStream() : DistributedDoubleCacheStream<Original> in class org.infinispan.stream.impl.tx.TxDistributedLongCacheStream |
From |
To |
|
Change Return Type DistributedIntCacheStream to DistributedIntCacheStream<Original> in method protected intCacheStream() : DistributedIntCacheStream<Original> in class org.infinispan.stream.impl.DistributedLongCacheStream |
From |
To |
|
Change Return Type DistributedLongCacheStream to DistributedLongCacheStream<Original> in method protected longCacheStream() : DistributedLongCacheStream<Original> in class org.infinispan.stream.impl.tx.TxDistributedIntCacheStream |
From |
To |
|
Change Return Type Supplier<Stream<CacheEntry>> to Supplier<Stream<Original>> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Return Type Supplier<Stream<CacheEntry>> to Supplier<Stream<Original>> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, usePrimary boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Return Type Stream<CacheEntry<K,V>> to Stream<Original> in method private getRehashStream(cacheEntrySet CacheSet<Original>, requestId Object, listener SegmentListener, parallelStream boolean, entryStream boolean, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Set<K>) : Stream<Original> in class org.infinispan.stream.impl.LocalStreamManagerImpl |
From |
To |
|
Change Return Type Supplier<CacheStream<CacheEntry>> to Supplier<CacheStream<R>> in method protected supplierStreamCast(supplier Supplier) : Supplier<CacheStream<R>> in class org.infinispan.stream.impl.DistributedCacheStream |
From |
To |
|
Change Return Type DistributedCacheStream<R> to DistributedCacheStream<Original,R> in method protected cacheStream() : DistributedCacheStream<Original,R> in class org.infinispan.stream.impl.DistributedIntCacheStream |
From |
To |
|
Change Return Type Collection<CacheEntry<K,K>> to Collection<K> in method public performForEachOperation(response IntermediateCollector<Collection<K>>) : Collection<K> in class org.infinispan.stream.impl.termop.primitive.AbstractForEachIntOperation |
From |
To |
|
Change Return Type DistributedIntCacheStream to DistributedIntCacheStream<Original> in method protected intCacheStream() : DistributedIntCacheStream<Original> in class org.infinispan.stream.impl.tx.TxDistributedCacheStream |
From |
To |
|
Change Return Type DistributedLongCacheStream to DistributedLongCacheStream<Original> in method protected longCacheStream() : DistributedLongCacheStream<Original> in class org.infinispan.stream.impl.tx.TxDistributedCacheStream |
From |
To |
|
Change Return Type KeyTrackingTerminalOperation<Object,Integer,Object> to KeyTrackingTerminalOperation<Original,Object,Integer> in method package getForEach(consumer IntConsumer, supplier Supplier<Stream<Original>>) : KeyTrackingTerminalOperation<Original,Object,Integer> in class org.infinispan.stream.impl.DistributedIntCacheStream |
From |
To |
|
Change Return Type DistributedCacheStream<R> to DistributedCacheStream<Original,R> in method protected cacheStream() : DistributedCacheStream<Original,R> in class org.infinispan.stream.impl.DistributedLongCacheStream |
From |
To |
|
Change Return Type DistributedCacheStream<R> to DistributedCacheStream<Original,R> in method protected cacheStream() : DistributedCacheStream<Original,R> in class org.infinispan.stream.impl.tx.TxDistributedIntCacheStream |
From |
To |
|
Change Return Type DistributedIntCacheStream to DistributedIntCacheStream<Original> in method protected intCacheStream() : DistributedIntCacheStream<Original> in class org.infinispan.stream.impl.tx.TxDistributedDoubleCacheStream |
From |
To |
|
Change Return Type DistributedLongCacheStream to DistributedLongCacheStream<Original> in method protected longCacheStream() : DistributedLongCacheStream<Original> in class org.infinispan.stream.impl.tx.TxDistributedDoubleCacheStream |
From |
To |
|
Change Return Type KeyTrackingTerminalOperation<Object,Long,Object> to KeyTrackingTerminalOperation<Original,Object,Long> in method package getForEach(consumer ObjLongConsumer<Cache<K,V>>, supplier Supplier<Stream<Original>>) : KeyTrackingTerminalOperation<Original,Object,Long> in class org.infinispan.stream.impl.DistributedLongCacheStream |
From |
To |
|
Change Return Type Supplier<Stream<CacheEntry>> to Supplier<Stream<Original>> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedCacheStream |
From |
To |
|
Change Return Type DistributedDoubleCacheStream to DistributedDoubleCacheStream<Original> in method protected doubleCacheStream() : DistributedDoubleCacheStream<Original> in class org.infinispan.stream.impl.DistributedIntCacheStream |
From |
To |
|
Change Return Type KeyTrackingTerminalOperation<Object,Long,Object> to KeyTrackingTerminalOperation<Original,Object,Long> in method package getForEach(consumer LongConsumer, supplier Supplier<Stream<Original>>) : KeyTrackingTerminalOperation<Original,Object,Long> in class org.infinispan.stream.impl.DistributedLongCacheStream |
From |
To |
|
Change Return Type Supplier<Stream<CacheEntry>> to Supplier<Stream<Original>> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedIntCacheStream |
From |
To |
|
Change Return Type Collection<CacheEntry<K,K>> to Collection<K> in method public performForEachOperation(response IntermediateCollector<Collection<K>>) : Collection<K> in class org.infinispan.stream.impl.termop.primitive.AbstractForEachLongOperation |
From |
To |
|
Change Return Type DistributedIntCacheStream to DistributedIntCacheStream<Original> in method protected intCacheStream() : DistributedIntCacheStream<Original> in class org.infinispan.stream.impl.tx.TxDistributedLongCacheStream |
From |
To |
|
Change Return Type KeyTrackingTerminalOperation<Object,Integer,Object> to KeyTrackingTerminalOperation<Original,Object,Integer> in method package getForEach(consumer ObjIntConsumer<Cache<K,V>>, supplier Supplier<Stream<Original>>) : KeyTrackingTerminalOperation<Original,Object,Integer> in class org.infinispan.stream.impl.DistributedIntCacheStream |
From |
To |
|
Change Return Type DistributedDoubleCacheStream to DistributedDoubleCacheStream<Original> in method protected doubleCacheStream() : DistributedDoubleCacheStream<Original> in class org.infinispan.stream.impl.DistributedLongCacheStream |
From |
To |
|
Change Return Type DistributedCacheStream<R> to DistributedCacheStream<Original,R> in method protected cacheStream() : DistributedCacheStream<Original,R> in class org.infinispan.stream.impl.tx.TxDistributedDoubleCacheStream |
From |
To |
|
Change Return Type DistributedDoubleCacheStream to DistributedDoubleCacheStream<Original> in method protected doubleCacheStream() : DistributedDoubleCacheStream<Original> in class org.infinispan.stream.impl.tx.TxDistributedIntCacheStream |
From |
To |
|
Change Return Type KeyTrackingTerminalOperation<Object,Double,Object> to KeyTrackingTerminalOperation<Original,Object,Double> in method package getForEach(consumer ObjDoubleConsumer<Cache<K,V>>, supplier Supplier<Stream<Original>>) : KeyTrackingTerminalOperation<Original,Object,Double> in class org.infinispan.stream.impl.DistributedDoubleCacheStream |
From |
To |
|
Change Return Type DistributedIntCacheStream to DistributedIntCacheStream<Original> in method protected intCacheStream() : DistributedIntCacheStream<Original> in class org.infinispan.stream.impl.DistributedDoubleCacheStream |
From |
To |
|
Change Return Type DistributedLongCacheStream to DistributedLongCacheStream<Original> in method protected longCacheStream() : DistributedLongCacheStream<Original> in class org.infinispan.stream.impl.DistributedDoubleCacheStream |
From |
To |
|
Change Return Type Stream<CacheEntry<K,V>> to Stream<Original> in method private getStream(cacheEntrySet CacheSet<Original>, parallelStream boolean, entryStream boolean, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Set<K>) : Stream<Original> in class org.infinispan.stream.impl.LocalStreamManagerImpl |
From |
To |
|
Change Return Type Collection<CacheEntry<K,K>> to Collection<K> in method public performForEachOperation(response IntermediateCollector<Collection<K>>) : Collection<K> in class org.infinispan.stream.impl.termop.AbstractForEachOperation |
From |
To |
|
Change Variable Type set : Set<CacheEntry> to set : Set<Original> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedLongCacheStream |
From |
To |
|
Change Variable Type collectedValues : List<CacheEntry<K,K>> to collectedValues : List<K> in method public performForEachOperation(response IntermediateCollector<Collection<K>>) : Collection<K> in class org.infinispan.stream.impl.termop.primitive.AbstractForEachIntOperation |
From |
To |
|
Change Variable Type set : Set<CacheEntry> to set : Set<Original> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedDoubleCacheStream |
From |
To |
|
Change Variable Type realManager : ClusterStreamManager<K> to realManager : ClusterStreamManager<K,K> in method public parallelStream() : CacheStream<K> in class org.infinispan.interceptors.distribution.DistributionBulkInterceptor.TxBackingKeySet |
From |
To |
|
Change Variable Type op : TerminalOperation<R> to op : TerminalOperation<Original,R> in method package performOperationRehashAware(function Function<? super S2,? extends R>, retryOnRehash boolean, remoteResults ResultsAccumulator<R>, earlyTerminatePredicate Predicate<? super R>) : R in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Variable Type realManager : ClusterStreamManager<K> to realManager : ClusterStreamManager<K,K> in method public stream() : CacheStream<K> in class org.infinispan.interceptors.distribution.DistributionBulkInterceptor.TxBackingKeySet |
From |
To |
|
Change Variable Type suppliedStream : Stream<CacheEntry> to suppliedStream : Stream<Original> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedIntCacheStream |
From |
To |
|
Change Variable Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedLongCacheStream |
From |
To |
|
Change Variable Type realManager : ClusterStreamManager<K> to realManager : ClusterStreamManager<CacheEntry<K,V>,K> in method public parallelStream() : CacheStream<CacheEntry<K,V>> in class org.infinispan.interceptors.distribution.DistributionBulkInterceptor.TxBackingEntrySet |
From |
To |
|
Change Variable Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedDoubleCacheStream |
From |
To |
|
Change Variable Type set : Set<CacheEntry> to set : Set<Original> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedIntCacheStream |
From |
To |
|
Change Variable Type realManager : ClusterStreamManager<K> to realManager : ClusterStreamManager<CacheEntry<K,V>,K> in method public stream() : CacheStream<CacheEntry<K,V>> in class org.infinispan.interceptors.distribution.DistributionBulkInterceptor.TxBackingEntrySet |
From |
To |
|
Change Variable Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method package localPublisher(segmentsToFilter IntSet, ch ConsistentHash, excludedKeys Set<Object>, intermediateOperations Iterable<IntermediateOperation>, stayLocal boolean) : Publisher<S> in class org.infinispan.stream.impl.DistributedCacheStream |
From |
To |
|
Change Variable Type stream : DistributedCacheStream<Double> to stream : DistributedCacheStream<Original,Double> in method package remoteIterator() : PrimitiveIterator.OfDouble in class org.infinispan.stream.impl.DistributedDoubleCacheStream |
From |
To |
|
Change Variable Type command : StreamResponseCommand<Collection<CacheEntry<K,R2>>> to command : StreamResponseCommand<Collection<K>> in method public streamOperationRehashAware(requestId Object, origin Address, parallelStream boolean, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Set<K>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,?>) : void in class org.infinispan.stream.impl.LocalStreamManagerImpl |
From |
To |
|
Change Variable Type suppliedStream : Stream<CacheEntry> to suppliedStream : Stream<Original> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedDoubleCacheStream |
From |
To |
|
Change Variable Type set : Set<CacheEntry> to set : Set<Original> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedCacheStream |
From |
To |
|
Change Variable Type op : KeyTrackingTerminalOperation<Object,? extends T,Object> to op : KeyTrackingTerminalOperation<Original,Object,? extends T> in method package performRehashKeyTrackingOperation(function Function<Supplier<Stream<Original>>,KeyTrackingTerminalOperation<Original,Object,? extends T>>) : void in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Variable Type collectedValues : List<CacheEntry<K,K>> to collectedValues : List<K> in method public performForEachOperation(response IntermediateCollector<Collection<K>>) : Collection<K> in class org.infinispan.stream.impl.termop.primitive.AbstractForEachLongOperation |
From |
To |
|
Change Variable Type txManager : TxClusterStreamManager<K> to txManager : TxClusterStreamManager<K,K> in method public parallelStream() : CacheStream<K> in class org.infinispan.interceptors.distribution.DistributionBulkInterceptor.TxBackingKeySet |
From |
To |
|
Change Variable Type tracker : RequestTracker<Map<K,R2>> to tracker : RequestTracker<Collection<K>> in method public remoteStreamOperationRehashAware(parallelDistribution boolean, parallelStream boolean, ch ConsistentHash, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Map<Integer,Set<K>>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,?>, callback ResultsCallback<Collection<K>>) : Object in class org.infinispan.stream.impl.ClusterStreamManagerImpl |
From |
To |
|
Change Variable Type stream : CacheStream<CacheEntry> to stream : CacheStream<Original> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, usePrimary boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Variable Type txManager : TxClusterStreamManager<K> to txManager : TxClusterStreamManager<K,K> in method public stream() : CacheStream<K> in class org.infinispan.interceptors.distribution.DistributionBulkInterceptor.TxBackingKeySet |
From |
To |
|
Change Variable Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedCacheStream |
From |
To |
|
Change Variable Type txManager : TxClusterStreamManager<K> to txManager : TxClusterStreamManager<CacheEntry<K,V>,K> in method public parallelStream() : CacheStream<CacheEntry<K,V>> in class org.infinispan.interceptors.distribution.DistributionBulkInterceptor.TxBackingEntrySet |
From |
To |
|
Change Variable Type op : TerminalOperation<R> to op : TerminalOperation<Original,R> in method package performOperation(function Function<? super S2,? extends R>, remoteResults ResultsAccumulator<R>, earlyTerminatePredicate Predicate<? super R>) : R in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Variable Type collectedValues : List<CacheEntry<K,K>> to collectedValues : List<K> in method public performForEachOperation(response IntermediateCollector<Collection<K>>) : Collection<K> in class org.infinispan.stream.impl.termop.AbstractForEachOperation |
From |
To |
|
Change Variable Type txManager : TxClusterStreamManager<K> to txManager : TxClusterStreamManager<CacheEntry<K,V>,K> in method public stream() : CacheStream<CacheEntry<K,V>> in class org.infinispan.interceptors.distribution.DistributionBulkInterceptor.TxBackingEntrySet |
From |
To |
|
Change Variable Type collectedValues : List<CacheEntry<K,K>> to collectedValues : List<K> in method public performForEachOperation(response IntermediateCollector<Collection<K>>) : Collection<K> in class org.infinispan.stream.impl.termop.primitive.AbstractForEachDoubleOperation |
From |
To |
|
Change Variable Type stream : DistributedCacheStream<Integer> to stream : DistributedCacheStream<Original,Integer> in method package remoteIterator() : PrimitiveIterator.OfInt in class org.infinispan.stream.impl.DistributedIntCacheStream |
From |
To |
|
Change Variable Type suppliedStream : Stream<CacheEntry> to suppliedStream : Stream<Original> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedLongCacheStream |
From |
To |
|
Change Variable Type stream : Stream<CacheEntry<K,V>> to stream : Stream<Original> in method private getStream(cacheEntrySet CacheSet<Original>, parallelStream boolean, entryStream boolean, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Set<K>) : Stream<Original> in class org.infinispan.stream.impl.LocalStreamManagerImpl |
From |
To |
|
Change Variable Type localValue : Collection<CacheEntry<Object,Object>> to localValue : Collection<Object> in method package performRehashKeyTrackingOperation(function Function<Supplier<Stream<Original>>,KeyTrackingTerminalOperation<Original,Object,? extends T>>) : void in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Variable Type results : KeyTrackingConsumer<Object,Object> to results : KeyTrackingConsumer<Object> in method package performRehashKeyTrackingOperation(function Function<Supplier<Stream<Original>>,KeyTrackingTerminalOperation<Original,Object,? extends T>>) : void in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Variable Type stream : DistributedCacheStream<Long> to stream : DistributedCacheStream<Original,Long> in method package remoteIterator() : PrimitiveIterator.OfLong in class org.infinispan.stream.impl.DistributedLongCacheStream |
From |
To |
|
Change Variable Type results : Collection<CacheEntry<K,R2>> to results : Collection<K> in method public streamOperationRehashAware(requestId Object, origin Address, parallelStream boolean, segments Set<Integer>, keysToInclude Set<K>, keysToExclude Set<K>, includeLoader boolean, entryStream boolean, operation KeyTrackingTerminalOperation<Original,K,?>) : void in class org.infinispan.stream.impl.LocalStreamManagerImpl |
From |
To |
|
Change Variable Type supplier : Supplier<Stream<CacheEntry>> to supplier : Supplier<Stream<Original>> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedIntCacheStream |
From |
To |
|
Change Variable Type suppliedStream : Stream<CacheEntry> to suppliedStream : Stream<Original> in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<Original>> in class org.infinispan.stream.impl.tx.TxDistributedCacheStream |
From |
To |