|
Pull Up Method public performOperationRehashAware(response IntermediateCollector<Collection<CacheEntry<K,K>>>) : Collection<CacheEntry<K,K>> from class org.infinispan.stream.impl.termop.primitive.ForEachDoubleOperation to public performOperationRehashAware(response IntermediateCollector<Collection<CacheEntry<K,K>>>) : Collection<CacheEntry<K,K>> from class org.infinispan.stream.impl.termop.primitive.AbstractForEachDoubleOperation |
From |
To |
|
Pull Up Method public getBatchSize() : int from class org.infinispan.stream.impl.termop.primitive.ForEachLongOperation to public getBatchSize() : int from class org.infinispan.stream.impl.termop.primitive.AbstractForEachLongOperation |
From |
To |
|
Pull Up Method public getBatchSize() : int from class org.infinispan.stream.impl.termop.primitive.ForEachDoubleOperation to public getBatchSize() : int from class org.infinispan.stream.impl.termop.primitive.AbstractForEachDoubleOperation |
From |
To |
|
Pull Up Method public lostSegment(stopIfLost boolean) : boolean from class org.infinispan.stream.impl.termop.primitive.ForEachDoubleOperation to public lostSegment(stopIfLost boolean) : boolean from class org.infinispan.stream.impl.termop.primitive.AbstractForEachDoubleOperation |
From |
To |
|
Pull Up Method public performOperation(response IntermediateCollector<Collection<Long>>) : List<Long> from class org.infinispan.stream.impl.termop.primitive.ForEachLongOperation to public performOperation(response IntermediateCollector<Collection<Long>>) : List<Long> from class org.infinispan.stream.impl.termop.primitive.AbstractForEachLongOperation |
From |
To |
|
Pull Up Method public lostSegment(stopIfLost boolean) : boolean from class org.infinispan.stream.impl.termop.primitive.ForEachLongOperation to public lostSegment(stopIfLost boolean) : boolean from class org.infinispan.stream.impl.termop.primitive.AbstractForEachLongOperation |
From |
To |
|
Pull Up Method public performOperation(response IntermediateCollector<Collection<Integer>>) : List<Integer> from class org.infinispan.stream.impl.termop.primitive.ForEachIntOperation to public performOperation(response IntermediateCollector<Collection<Integer>>) : List<Integer> from class org.infinispan.stream.impl.termop.primitive.AbstractForEachIntOperation |
From |
To |
|
Pull Up Method public performOperationRehashAware(response IntermediateCollector<Collection<CacheEntry<K,K>>>) : Collection<CacheEntry<K,K>> from class org.infinispan.stream.impl.termop.primitive.ForEachIntOperation to public performOperationRehashAware(response IntermediateCollector<Collection<CacheEntry<K,K>>>) : Collection<CacheEntry<K,K>> from class org.infinispan.stream.impl.termop.primitive.AbstractForEachIntOperation |
From |
To |
|
Pull Up Method public getBatchSize() : int from class org.infinispan.stream.impl.termop.primitive.ForEachIntOperation to public getBatchSize() : int from class org.infinispan.stream.impl.termop.primitive.AbstractForEachIntOperation |
From |
To |
|
Pull Up Method public lostSegment(stopIfLost boolean) : boolean from class org.infinispan.stream.impl.termop.primitive.ForEachIntOperation to public lostSegment(stopIfLost boolean) : boolean from class org.infinispan.stream.impl.termop.primitive.AbstractForEachIntOperation |
From |
To |
|
Pull Up Method public performOperationRehashAware(response IntermediateCollector<Collection<CacheEntry<K,K>>>) : Collection<CacheEntry<K,K>> from class org.infinispan.stream.impl.termop.primitive.ForEachLongOperation to public performOperationRehashAware(response IntermediateCollector<Collection<CacheEntry<K,K>>>) : Collection<CacheEntry<K,K>> from class org.infinispan.stream.impl.termop.primitive.AbstractForEachLongOperation |
From |
To |
|
Pull Up Method public performOperation(response IntermediateCollector<Collection<Double>>) : List<Double> from class org.infinispan.stream.impl.termop.primitive.ForEachDoubleOperation to public performOperation(response IntermediateCollector<Collection<Double>>) : List<Double> from class org.infinispan.stream.impl.termop.primitive.AbstractForEachDoubleOperation |
From |
To |
|
Change Parameter Type function : Function<S,? extends R> to function : Function<? super S2,? extends 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 Parameter Type function : Function<S,? extends E> to function : Function<? super S2,? extends E> in method public SegmentRetryingOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<? extends Stream<?>>, function Function<? super S2,? extends E>) in class org.infinispan.stream.impl.termop.SegmentRetryingOperation |
From |
To |
|
Change Parameter Type function : Function<S,? extends E> to function : Function<? super S2,? extends E> in method public SingleRunOperation(intermediateOperations Iterable<IntermediateOperation>, supplier Supplier<? extends BaseStream<?,?>>, function Function<? super S2,? extends E>) in class org.infinispan.stream.impl.termop.SingleRunOperation |
From |
To |
|
Change Parameter Type other : AbstractCacheStream<T,S,S2,T_CONS> to other : AbstractCacheStream<T,S,S2> in method protected AbstractCacheStream(other AbstractCacheStream<T,S,S2>) in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Parameter Type function : Function<S,? extends R> to function : Function<? super S2,? extends R> in method package performObjIntermediateRemoteOperation(function Function<? super S2,? extends R>) : R in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Parameter Type function : Function<S,? extends R> to function : Function<? super S2,? extends R> in method package performOperation(function Function<? super S2,? extends R>, retryOnRehash boolean, accumulator BinaryOperator<R>, earlyTerminatePredicate Predicate<? super R>, ignoreSorting boolean) : R in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Parameter Type function : Function<S,? extends R> to function : Function<? super S2,? extends R> in method package performDoubleIntermediateRemoteOperation(function Function<? super S2,? extends R>) : R in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Parameter Type function : Function<S,? extends R> to function : Function<? super S2,? extends R> in method package performLongIntermediateRemoteOperation(function Function<? super S2,? extends R>) : R in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Parameter Type function : Function<S,? extends R> to function : Function<? super S2,? extends R> in method package performIntermediateRemoteOperation(function Function<? super S2,? extends R>) : R in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Parameter Type function : Function<S,? extends R> to function : Function<? super S2,? extends 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 Parameter Type function : Function<S,? extends R> to function : Function<? super S2,? extends R> in method package performOperation(function Function<? super S2,? extends R>, retryOnRehash boolean, accumulator BinaryOperator<R>, earlyTerminatePredicate Predicate<? super R>) : R in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Parameter Type function : Function<S,? extends R> to function : Function<? super S2,? extends R> in method package performIntegerIntermediateRemoteOperation(function Function<? super S2,? extends R>) : R in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Variable Type op : SingleRunOperation<R,T,S> to op : SingleRunOperation<R,T,S,S2> in method package performIntegerIntermediateRemoteOperation(function Function<? super S2,? extends R>) : R in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Variable Type op : SingleRunOperation<R,T,S> to op : SingleRunOperation<R,T,S,S2> in method package performDoubleIntermediateRemoteOperation(function Function<? super S2,? extends R>) : R in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Variable Type op : SingleRunOperation<R,T,S> to op : SingleRunOperation<R,T,S,S2> in method package performLongIntermediateRemoteOperation(function Function<? super S2,? extends R>) : R in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |
|
Change Variable Type op : SingleRunOperation<R,T,S> to op : SingleRunOperation<R,T,S,S2> in method package performObjIntermediateRemoteOperation(function Function<? super S2,? extends R>) : R in class org.infinispan.stream.impl.AbstractCacheStream |
From |
To |