|
Change Parameter Type hash : ConsistentHash to toIntFunction : ToIntFunction<Object> in method public KeyStreamSupplier(cache Cache<K,V>, toIntFunction ToIntFunction<Object>, supplier Supplier<Stream<K>>) in class org.infinispan.stream.impl.local.KeyStreamSupplier |
From |
To |
|
Change Parameter Type hash : ConsistentHash to toIntFunction : ToIntFunction<Object> in method public EntryStreamSupplier(cache Cache<K,V>, toIntFunction ToIntFunction<Object>, supplier Supplier<Stream<CacheEntry<K,V>>>) in class org.infinispan.stream.impl.local.EntryStreamSupplier |
From |
To |
|
Change Parameter Type stream : Stream<R> to stream : BaseStream<R,Stream<R>> in method public spliterator(stream BaseStream<R,Stream<R>>) : CloseableSpliterator<R> in class org.infinispan.commons.util.Closeables |
From |
To |
|
Change Parameter Type stream : Stream<T> to stream : BaseStream<T,Stream<T>> in method public StreamToCloseableSpliterator(stream BaseStream<T,Stream<T>>) in class org.infinispan.commons.util.Closeables.StreamToCloseableSpliterator |
From |
To |
|
Change Parameter Type stateTransferLock : StateTransferLock to iteratorHandler : IteratorHandler in method public setupDependencies(container DataContainer, notifier CacheNotifier<Object,Object>, cache Cache<Object,Object>, interceptorChain AsyncInterceptorChain, distributionManager DistributionManager, icf InvocationContextFactory, txTable TransactionTable, configuration Configuration, moduleCommandInitializers Map<Byte,ModuleCommandInitializer>, recoveryManager RecoveryManager, stateProvider StateProvider, stateConsumer StateConsumer, lockManager LockManager, entryFactory InternalEntryFactory, stm StateTransferManager, backupSender BackupSender, cancellationService CancellationService, xSiteStateProvider XSiteStateProvider, xSiteStateConsumer XSiteStateConsumer, xSiteStateTransferManager XSiteStateTransferManager, groupManager GroupManager, localStreamManager LocalStreamManager, clusterStreamManager ClusterStreamManager, clusteringDependentLogic ClusteringDependentLogic, marshaller StreamingMarshaller, commandAckCollector CommandAckCollector, stateReceiver StateReceiver, componentRegistry ComponentRegistry, orderedUpdatesManager OrderedUpdatesManager, iteratorHandler IteratorHandler) : void in class org.infinispan.commands.CommandsFactoryImpl |
From |
To |
|
Change Parameter Type componentType : Class<T> to componentType : Class<? extends T> in method public replaceComponent(cacheContainer CacheContainer, componentType Class<? extends T>, replacementComponent T, rewire boolean) : T in class org.infinispan.test.TestingUtil |
From |
To |
|
Change Parameter Type targetSegments : Set<Integer> to targetSegments : IntSet in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<CacheEntry>> in class org.infinispan.stream.impl.tx.TxDistributedLongCacheStream |
From |
To |
|
Change Parameter Type targetSegments : Set<Integer> to targetSegments : IntSet in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<CacheEntry>> in class org.infinispan.stream.impl.tx.TxDistributedIntCacheStream |
From |
To |
|
Change Parameter Type stream : Stream<? extends E> to stream : BaseStream<E,Stream<E>> in method public StreamToCloseableIterator(stream BaseStream<E,Stream<E>>) in class org.infinispan.commons.util.Closeables.StreamToCloseableIterator |
From |
To |
|
Change Parameter Type b : CacheStream.SegmentCompletionListener to b : Consumer<Supplier<PrimitiveIterator.OfInt>> in method protected composeWithExceptions(a Consumer<Supplier<PrimitiveIterator.OfInt>>, b Consumer<Supplier<PrimitiveIterator.OfInt>>) : Consumer<Supplier<PrimitiveIterator.OfInt>> in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Parameter Type stream : Stream<? extends R> to stream : BaseStream<R,Stream<R>> in method public iterator(stream BaseStream<R,Stream<R>>) : CloseableIterator<R> in class org.infinispan.commons.util.Closeables |
From |
To |
|
Change Parameter Type targetSegments : Set<Integer> to targetSegments : IntSet in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>) : Supplier<Stream<CacheEntry>> in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Parameter Type targetSegments : Set<Integer> to targetSegments : IntSet in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<CacheEntry>> in class org.infinispan.stream.impl.tx.TxDistributedCacheStream |
From |
To |
|
Change Parameter Type a : CacheStream.SegmentCompletionListener to a : Consumer<Supplier<PrimitiveIterator.OfInt>> in method protected composeWithExceptions(a Consumer<Supplier<PrimitiveIterator.OfInt>>, b Consumer<Supplier<PrimitiveIterator.OfInt>>) : Consumer<Supplier<PrimitiveIterator.OfInt>> in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Parameter Type targetSegments : Set<Integer> to targetSegments : IntSet in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, primaryOnly boolean) : Supplier<Stream<CacheEntry>> in class org.infinispan.stream.impl.tx.TxDistributedDoubleCacheStream |
From |
To |
|
Change Parameter Type componentType : Class<T> to componentType : Class<? extends T> in method public replaceComponent(cache Cache<?,?>, componentType Class<? extends T>, replacementComponent T, rewire boolean) : T in class org.infinispan.test.TestingUtil |
From |
To |
|
Change Parameter Type targetSegments : Set<Integer> to targetSegments : IntSet in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, usePrimary boolean) : Supplier<Stream<CacheEntry>> in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Variable Type segmentsToProcess : Set<Integer> to segmentsToProcess : IntSet in method package performRehashKeyTrackingOperation(function Function<Supplier<Stream<CacheEntry>>,KeyTrackingTerminalOperation<Object,? extends T,Object>>) : void in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Variable Type cacheTopology : LocalizedCacheTopology to cacheTopology : CacheTopology 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 segments : Set<Integer> to segments : Supplier<PrimitiveIterator.OfInt> in method public putIfAbsent(key UUID, value QueueingSegmentListener) : QueueingSegmentListener in class org.infinispan.notifications.cachelistener.CacheNotifierImplInitialTransferDistTest.waitUntilClosingSegment.listeningMap |
From |
To |
|
Change Variable Type cacheTopology : LocalizedCacheTopology to cacheTopology : CacheTopology in method package performRehashKeyTrackingOperation(function Function<Supplier<Stream<CacheEntry>>,KeyTrackingTerminalOperation<Object,? extends T,Object>>) : void in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Variable Type segments : Set<Integer> to segments : IntSet in method protected supplierForSegments(ch ConsistentHash, targetSegments IntSet, excludedKeys Set<Object>, usePrimary boolean) : Supplier<Stream<CacheEntry>> in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Variable Type segmentsToProcess : Set<Integer> to segmentsToProcess : IntSet 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 |
|
Pull Up Method public equals(o Object) : boolean from class org.infinispan.util.RangeSet to public equals(o Object) : boolean from class org.infinispan.commons.util.RangeSet |
From |
To |
|
Pull Up Method public retainAll(c Collection<?>) : boolean from class org.infinispan.util.RangeSet to public retainAll(c Collection<?>) : boolean from class org.infinispan.commons.util.RangeSet |
From |
To |
|
Pull Up Method public hashCode() : int from class org.infinispan.util.RangeSet to public hashCode() : int from class org.infinispan.commons.util.RangeSet |
From |
To |
|
Pull Up Method public clear() : void from class org.infinispan.util.RangeSet to public clear() : void from class org.infinispan.commons.util.RangeSet |
From |
To |
|
Pull Up Method public toArray() : Object[] from class org.infinispan.util.RangeSet to public toArray() : Object[] from class org.infinispan.commons.util.RangeSet |
From |
To |
|
Pull Up Method public add(integer Integer) : boolean from class org.infinispan.util.RangeSet to public add(integer Integer) : boolean from class org.infinispan.commons.util.RangeSet |
From |
To |
|
Pull Up Method public remove(o Object) : boolean from class org.infinispan.util.RangeSet to public remove(o Object) : boolean from class org.infinispan.commons.util.RangeSet |
From |
To |
|
Pull Up Method public containsAll(c Collection<?>) : boolean from class org.infinispan.util.RangeSet to public containsAll(c Collection<?>) : boolean from class org.infinispan.commons.util.RangeSet |
From |
To |
|
Pull Up Method public removeAll(c Collection<?>) : boolean from class org.infinispan.util.RangeSet to public removeAll(c Collection<?>) : boolean from class org.infinispan.commons.util.RangeSet |
From |
To |
|
Pull Up Method public isEmpty() : boolean from class org.infinispan.util.RangeSet to public isEmpty() : boolean from class org.infinispan.commons.util.RangeSet |
From |
To |
|
Pull Up Method public addAll(c Collection<? extends Integer>) : boolean from class org.infinispan.util.RangeSet to public addAll(c Collection<? extends Integer>) : boolean from class org.infinispan.commons.util.RangeSet |
From |
To |
|
Pull Up Method public size() : int from class org.infinispan.util.RangeSet to public size() : int from class org.infinispan.commons.util.RangeSet |
From |
To |
|
Pull Up Method public toString() : String from class org.infinispan.util.RangeSet to public toString() : String from class org.infinispan.commons.util.RangeSet |
From |
To |
|
Pull Up Method public contains(o Object) : boolean from class org.infinispan.util.RangeSet to public contains(o Object) : boolean from class org.infinispan.commons.util.RangeSet |
From |
To |
|
Pull Up Method public toArray(a T[]) : T[] from class org.infinispan.util.RangeSet to public toArray(a T[]) : T[] from class org.infinispan.commons.util.RangeSet |
From |
To |
|
Rename Parameter stateTransferLock : StateTransferLock to iteratorHandler : IteratorHandler in method public setupDependencies(container DataContainer, notifier CacheNotifier<Object,Object>, cache Cache<Object,Object>, interceptorChain AsyncInterceptorChain, distributionManager DistributionManager, icf InvocationContextFactory, txTable TransactionTable, configuration Configuration, moduleCommandInitializers Map<Byte,ModuleCommandInitializer>, recoveryManager RecoveryManager, stateProvider StateProvider, stateConsumer StateConsumer, lockManager LockManager, entryFactory InternalEntryFactory, stm StateTransferManager, backupSender BackupSender, cancellationService CancellationService, xSiteStateProvider XSiteStateProvider, xSiteStateConsumer XSiteStateConsumer, xSiteStateTransferManager XSiteStateTransferManager, groupManager GroupManager, localStreamManager LocalStreamManager, clusterStreamManager ClusterStreamManager, clusteringDependentLogic ClusteringDependentLogic, marshaller StreamingMarshaller, commandAckCollector CommandAckCollector, stateReceiver StateReceiver, componentRegistry ComponentRegistry, orderedUpdatesManager OrderedUpdatesManager, iteratorHandler IteratorHandler) : void in class org.infinispan.commands.CommandsFactoryImpl |
From |
To |
|
Rename Parameter hash : ConsistentHash to toIntFunction : ToIntFunction<Object> in method public KeyStreamSupplier(cache Cache<K,V>, toIntFunction ToIntFunction<Object>, supplier Supplier<Stream<K>>) in class org.infinispan.stream.impl.local.KeyStreamSupplier |
From |
To |
|
Rename Parameter hash : ConsistentHash to toIntFunction : ToIntFunction<Object> in method public EntryStreamSupplier(cache Cache<K,V>, toIntFunction ToIntFunction<Object>, supplier Supplier<Stream<CacheEntry<K,V>>>) in class org.infinispan.stream.impl.local.EntryStreamSupplier |
From |
To |