Class TriangleFunctionsUtil

java.lang.Object

org.infinispan.util.TriangleFunctionsUtil

public final class TriangleFunctionsUtil
extends Object

Some utility functions for TriangleDistributionInterceptor.

Since:

9.2

Author:

Pedro Ruivo

Method Summary

Modifier and Type	Method	Description
static <K,V,R> ReadWriteManyCommand<K,V,R>	copy(ReadWriteManyCommand<K,V,R> command, Collection<Object> keys)
static <K,V,T,R> ReadWriteManyEntriesCommand<K,V,T,R>	copy(ReadWriteManyEntriesCommand<K,V,T,R> command, Collection<Object> keys)
static <K,V> WriteOnlyManyCommand<K,V>	copy(WriteOnlyManyCommand<K,V> command, Collection<Object> keys)
static <K,V,T> WriteOnlyManyEntriesCommand<K,V,T>	copy(WriteOnlyManyEntriesCommand<K,V,T> command, Collection<Object> keys)
static PutMapCommand	copy(PutMapCommand command, Collection<Object> keys)
static Map<Integer, Collection<Object>>	filterBySegment(LocalizedCacheTopology cacheTopology, Collection<Object> keys)
static <K,V> Map<K,V>	filterEntries(Map<K,V> map, Collection<Object> keys)
static Map<Object,Object>	mergeHashMap(ValidResponse response, Map<Object,Object> resultMap)
static List<Object>	mergeList(ValidResponse response, List<Object> resultList)
static Void	voidMerge(ValidResponse ignored1, Void ignored2)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

copy

public static PutMapCommand copy(PutMapCommand command,
 Collection<Object> keys)

copy

public static <K,V,T>
WriteOnlyManyEntriesCommand<K,V,T> copy(WriteOnlyManyEntriesCommand<K,V,T> command,
 Collection<Object> keys)

copy

public static <K,V> WriteOnlyManyCommand<K,V> copy(WriteOnlyManyCommand<K,V> command,
 Collection<Object> keys)

copy

public static <K,V,R> ReadWriteManyCommand<K,V,R> copy(ReadWriteManyCommand<K,V,R> command,
 Collection<Object> keys)

copy

public static <K,V,T,R>
ReadWriteManyEntriesCommand<K,V,T,R> copy(ReadWriteManyEntriesCommand<K,V,T,R> command,
 Collection<Object> keys)

mergeHashMap

public static Map<Object,Object> mergeHashMap(ValidResponse response,
 Map<Object,Object> resultMap)

voidMerge

public static Void voidMerge(ValidResponse ignored1,
 Void ignored2)

mergeList

public static List<Object> mergeList(ValidResponse response,
 List<Object> resultList)

filterBySegment

public static Map<Integer, Collection<Object>> filterBySegment(LocalizedCacheTopology cacheTopology,
 Collection<Object> keys)

filterEntries

public static <K,V> Map<K,V> filterEntries(Map<K,V> map,
 Collection<Object> keys)