int |
RScoredSortedSet.intersection(RScoredSortedSet.Aggregate aggregate,
String... names) |
Intersect provided ScoredSortedSets with defined aggregation method
and store result to current ScoredSortedSet
|
int |
RScoredSortedSet.intersection(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Intersect provided ScoredSortedSets mapped to weight multiplier
with defined aggregation method
and store result to current ScoredSortedSet
|
reactor.core.publisher.Mono<Integer> |
RScoredSortedSetReactive.intersection(RScoredSortedSet.Aggregate aggregate,
String... names) |
Intersect provided ScoredSortedSets with defined aggregation method
and store result to current ScoredSortedSet
|
reactor.core.publisher.Mono<Integer> |
RScoredSortedSetReactive.intersection(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Intersect provided ScoredSortedSets mapped to weight multiplier
with defined aggregation method
and store result to current ScoredSortedSet
|
io.reactivex.rxjava3.core.Single<Integer> |
RScoredSortedSetRx.intersection(RScoredSortedSet.Aggregate aggregate,
String... names) |
Intersect provided ScoredSortedSets with defined aggregation method
and store result to current ScoredSortedSet
|
io.reactivex.rxjava3.core.Single<Integer> |
RScoredSortedSetRx.intersection(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Intersect provided ScoredSortedSets mapped to weight multiplier
with defined aggregation method
and store result to current ScoredSortedSet
|
RFuture<Integer> |
RScoredSortedSetAsync.intersectionAsync(RScoredSortedSet.Aggregate aggregate,
String... names) |
Intersect provided ScoredSortedSets with defined aggregation method
and store result to current ScoredSortedSet
|
RFuture<Integer> |
RScoredSortedSetAsync.intersectionAsync(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Intersect provided ScoredSortedSets mapped to weight multiplier
with defined aggregation method
and store result to current ScoredSortedSet
|
Collection<V> |
RScoredSortedSet.readIntersection(RScoredSortedSet.Aggregate aggregate,
String... names) |
Intersect provided ScoredSortedSets with current ScoredSortedSet using defined aggregation method
without state change
|
Collection<V> |
RScoredSortedSet.readIntersection(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Intersect provided ScoredSortedSets mapped to weight multiplier
with current ScoredSortedSet using defined aggregation method
without state change
|
reactor.core.publisher.Mono<Collection<V>> |
RScoredSortedSetReactive.readIntersection(RScoredSortedSet.Aggregate aggregate,
String... names) |
Intersect provided ScoredSortedSets with current ScoredSortedSet using defined aggregation method
without state change
|
reactor.core.publisher.Mono<Collection<V>> |
RScoredSortedSetReactive.readIntersection(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Intersect provided ScoredSortedSets mapped to weight multiplier
with current ScoredSortedSet using defined aggregation method
without state change
|
io.reactivex.rxjava3.core.Single<Collection<V>> |
RScoredSortedSetRx.readIntersection(RScoredSortedSet.Aggregate aggregate,
String... names) |
Intersect provided ScoredSortedSets with current ScoredSortedSet using defined aggregation method
without state change
|
io.reactivex.rxjava3.core.Single<Collection<V>> |
RScoredSortedSetRx.readIntersection(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Intersect provided ScoredSortedSets mapped to weight multiplier
with current ScoredSortedSet using defined aggregation method
without state change
|
RFuture<Collection<V>> |
RScoredSortedSetAsync.readIntersectionAsync(RScoredSortedSet.Aggregate aggregate,
String... names) |
Intersect provided ScoredSortedSets with current ScoredSortedSet using defined aggregation method
without state change
|
RFuture<Collection<V>> |
RScoredSortedSetAsync.readIntersectionAsync(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Intersect provided ScoredSortedSets mapped to weight multiplier
with current ScoredSortedSet using defined aggregation method
without state change
|
Collection<V> |
RScoredSortedSet.readUnion(RScoredSortedSet.Aggregate aggregate,
String... names) |
Union ScoredSortedSets specified by name with defined aggregation method
and current ScoredSortedSet without state change.
|
Collection<V> |
RScoredSortedSet.readUnion(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Union provided ScoredSortedSets mapped to weight multiplier
with defined aggregation method
and current ScoredSortedSet without state change
|
reactor.core.publisher.Mono<Collection<V>> |
RScoredSortedSetReactive.readUnion(RScoredSortedSet.Aggregate aggregate,
String... names) |
Union ScoredSortedSets specified by name with defined aggregation method
and current ScoredSortedSet without state change.
|
reactor.core.publisher.Mono<Collection<V>> |
RScoredSortedSetReactive.readUnion(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Union provided ScoredSortedSets mapped to weight multiplier
with defined aggregation method
and current ScoredSortedSet without state change
|
io.reactivex.rxjava3.core.Single<Collection<V>> |
RScoredSortedSetRx.readUnion(RScoredSortedSet.Aggregate aggregate,
String... names) |
Union ScoredSortedSets specified by name with defined aggregation method
and current ScoredSortedSet without state change.
|
io.reactivex.rxjava3.core.Single<Collection<V>> |
RScoredSortedSetRx.readUnion(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Union provided ScoredSortedSets mapped to weight multiplier
with defined aggregation method
and current ScoredSortedSet without state change
|
RFuture<Collection<V>> |
RScoredSortedSetAsync.readUnionAsync(RScoredSortedSet.Aggregate aggregate,
String... names) |
Union ScoredSortedSets specified by name with defined aggregation method
and current ScoredSortedSet without state change.
|
RFuture<Collection<V>> |
RScoredSortedSetAsync.readUnionAsync(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Union provided ScoredSortedSets mapped to weight multiplier
with defined aggregation method
and current ScoredSortedSet without state change
|
int |
RScoredSortedSet.union(RScoredSortedSet.Aggregate aggregate,
String... names) |
Union provided ScoredSortedSets with defined aggregation method
and store result to current ScoredSortedSet
|
int |
RScoredSortedSet.union(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Union provided ScoredSortedSets mapped to weight multiplier
with defined aggregation method
and store result to current ScoredSortedSet
|
reactor.core.publisher.Mono<Integer> |
RScoredSortedSetReactive.union(RScoredSortedSet.Aggregate aggregate,
String... names) |
Union provided ScoredSortedSets with defined aggregation method
and store result to current ScoredSortedSet
|
reactor.core.publisher.Mono<Integer> |
RScoredSortedSetReactive.union(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Union provided ScoredSortedSets mapped to weight multiplier
with defined aggregation method
and store result to current ScoredSortedSet
|
io.reactivex.rxjava3.core.Single<Integer> |
RScoredSortedSetRx.union(RScoredSortedSet.Aggregate aggregate,
String... names) |
Union provided ScoredSortedSets with defined aggregation method
and store result to current ScoredSortedSet
|
io.reactivex.rxjava3.core.Single<Integer> |
RScoredSortedSetRx.union(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Union provided ScoredSortedSets mapped to weight multiplier
with defined aggregation method
and store result to current ScoredSortedSet
|
RFuture<Integer> |
RScoredSortedSetAsync.unionAsync(RScoredSortedSet.Aggregate aggregate,
String... names) |
Union provided ScoredSortedSets with defined aggregation method
and store result to current ScoredSortedSet
|
RFuture<Integer> |
RScoredSortedSetAsync.unionAsync(RScoredSortedSet.Aggregate aggregate,
Map<String,Double> nameWithWeight) |
Union provided ScoredSortedSets mapped to weight multiplier
with defined aggregation method
and store result to current ScoredSortedSet
|