Package org.infinispan.util

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 org.infinispan.commands.triangle.BackupWriteCommand	backupFrom(org.infinispan.commands.CommandsFactory factory, org.infinispan.commands.functional.ReadWriteKeyCommand command)
static org.infinispan.commands.triangle.BackupWriteCommand	backupFrom(org.infinispan.commands.CommandsFactory factory, org.infinispan.commands.functional.ReadWriteKeyValueCommand command)
static <K,V,R> org.infinispan.commands.triangle.BackupWriteCommand	backupFrom(org.infinispan.commands.CommandsFactory factory, org.infinispan.commands.functional.ReadWriteManyCommand<K,V,R> command, Collection<Object> keys)
static <K,V,T,R> org.infinispan.commands.triangle.BackupWriteCommand	backupFrom(org.infinispan.commands.CommandsFactory factory, org.infinispan.commands.functional.ReadWriteManyEntriesCommand<K,V,T,R> command, Collection<Object> keys)
static org.infinispan.commands.triangle.BackupWriteCommand	backupFrom(org.infinispan.commands.CommandsFactory factory, org.infinispan.commands.functional.WriteOnlyKeyCommand command)
static org.infinispan.commands.triangle.BackupWriteCommand	backupFrom(org.infinispan.commands.CommandsFactory factory, org.infinispan.commands.functional.WriteOnlyKeyValueCommand command)
static <K,V> org.infinispan.commands.triangle.BackupWriteCommand	backupFrom(org.infinispan.commands.CommandsFactory factory, org.infinispan.commands.functional.WriteOnlyManyCommand<K,V> command, Collection<Object> keys)
static <K,V,T> org.infinispan.commands.triangle.BackupWriteCommand	backupFrom(org.infinispan.commands.CommandsFactory factory, org.infinispan.commands.functional.WriteOnlyManyEntriesCommand<K,V,T> command, Collection<Object> keys)
static org.infinispan.commands.triangle.BackupWriteCommand	backupFrom(org.infinispan.commands.CommandsFactory factory, org.infinispan.commands.write.ComputeCommand command)
static org.infinispan.commands.triangle.BackupWriteCommand	backupFrom(org.infinispan.commands.CommandsFactory factory, org.infinispan.commands.write.ComputeIfAbsentCommand command)
static org.infinispan.commands.triangle.BackupWriteCommand	backupFrom(org.infinispan.commands.CommandsFactory factory, org.infinispan.commands.write.PutKeyValueCommand command)
static org.infinispan.commands.triangle.BackupWriteCommand	backupFrom(org.infinispan.commands.CommandsFactory factory, org.infinispan.commands.write.PutMapCommand command, Collection<Object> keys)
static org.infinispan.commands.triangle.BackupWriteCommand	backupFrom(org.infinispan.commands.CommandsFactory factory, org.infinispan.commands.write.RemoveCommand command)
static org.infinispan.commands.triangle.BackupWriteCommand	backupFrom(org.infinispan.commands.CommandsFactory factory, org.infinispan.commands.write.ReplaceCommand command)
static <K,V,R> org.infinispan.commands.functional.ReadWriteManyCommand<K,V,R>	copy(org.infinispan.commands.functional.ReadWriteManyCommand<K,V,R> command, Collection<Object> keys)
static <K,V,T,R> org.infinispan.commands.functional.ReadWriteManyEntriesCommand<K,V,T,R>	copy(org.infinispan.commands.functional.ReadWriteManyEntriesCommand<K,V,T,R> command, Collection<Object> keys)
static <K,V> org.infinispan.commands.functional.WriteOnlyManyCommand<K,V>	copy(org.infinispan.commands.functional.WriteOnlyManyCommand<K,V> command, Collection<Object> keys)
static <K,V,T> org.infinispan.commands.functional.WriteOnlyManyEntriesCommand<K,V,T>	copy(org.infinispan.commands.functional.WriteOnlyManyEntriesCommand<K,V,T> command, Collection<Object> keys)
static org.infinispan.commands.write.PutMapCommand	copy(org.infinispan.commands.write.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 java.lang.Object

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

Method Detail

copy

public static org.infinispan.commands.write.PutMapCommand copy(org.infinispan.commands.write.PutMapCommand command,
                                                               Collection<Object> keys)

copy

public static <K,V,T> org.infinispan.commands.functional.WriteOnlyManyEntriesCommand<K,V,T> copy(org.infinispan.commands.functional.WriteOnlyManyEntriesCommand<K,V,T> command,
                                                                                                                         Collection<Object> keys)

copy

public static <K,V> org.infinispan.commands.functional.WriteOnlyManyCommand<K,V> copy(org.infinispan.commands.functional.WriteOnlyManyCommand<K,V> command,
                                                                                                  Collection<Object> keys)

copy

public static <K,V,R> org.infinispan.commands.functional.ReadWriteManyCommand<K,V,R> copy(org.infinispan.commands.functional.ReadWriteManyCommand<K,V,R> command,
                                                                                                                  Collection<Object> keys)

copy

public static <K,V,T,R> org.infinispan.commands.functional.ReadWriteManyEntriesCommand<K,V,T,R> copy(org.infinispan.commands.functional.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)

backupFrom

public static org.infinispan.commands.triangle.BackupWriteCommand backupFrom(org.infinispan.commands.CommandsFactory factory,
                                                                             org.infinispan.commands.write.PutKeyValueCommand command)

backupFrom

public static org.infinispan.commands.triangle.BackupWriteCommand backupFrom(org.infinispan.commands.CommandsFactory factory,
                                                                             org.infinispan.commands.write.RemoveCommand command)

backupFrom

public static org.infinispan.commands.triangle.BackupWriteCommand backupFrom(org.infinispan.commands.CommandsFactory factory,
                                                                             org.infinispan.commands.write.ReplaceCommand command)

backupFrom

public static org.infinispan.commands.triangle.BackupWriteCommand backupFrom(org.infinispan.commands.CommandsFactory factory,
                                                                             org.infinispan.commands.write.ComputeIfAbsentCommand command)

backupFrom

public static org.infinispan.commands.triangle.BackupWriteCommand backupFrom(org.infinispan.commands.CommandsFactory factory,
                                                                             org.infinispan.commands.write.ComputeCommand command)

backupFrom

public static org.infinispan.commands.triangle.BackupWriteCommand backupFrom(org.infinispan.commands.CommandsFactory factory,
                                                                             org.infinispan.commands.functional.ReadWriteKeyValueCommand command)

backupFrom

public static org.infinispan.commands.triangle.BackupWriteCommand backupFrom(org.infinispan.commands.CommandsFactory factory,
                                                                             org.infinispan.commands.functional.ReadWriteKeyCommand command)

backupFrom

public static org.infinispan.commands.triangle.BackupWriteCommand backupFrom(org.infinispan.commands.CommandsFactory factory,
                                                                             org.infinispan.commands.functional.WriteOnlyKeyValueCommand command)

backupFrom

public static org.infinispan.commands.triangle.BackupWriteCommand backupFrom(org.infinispan.commands.CommandsFactory factory,
                                                                             org.infinispan.commands.functional.WriteOnlyKeyCommand command)

backupFrom

public static org.infinispan.commands.triangle.BackupWriteCommand backupFrom(org.infinispan.commands.CommandsFactory factory,
                                                                             org.infinispan.commands.write.PutMapCommand command,
                                                                             Collection<Object> keys)

backupFrom

public static <K,V,T> org.infinispan.commands.triangle.BackupWriteCommand backupFrom(org.infinispan.commands.CommandsFactory factory,
                                                                                                 org.infinispan.commands.functional.WriteOnlyManyEntriesCommand<K,V,T> command,
                                                                                                 Collection<Object> keys)

backupFrom

public static <K,V,T,R> org.infinispan.commands.triangle.BackupWriteCommand backupFrom(org.infinispan.commands.CommandsFactory factory,
                                                                                                         org.infinispan.commands.functional.ReadWriteManyEntriesCommand<K,V,T,R> command,
                                                                                                         Collection<Object> keys)

backupFrom

public static <K,V> org.infinispan.commands.triangle.BackupWriteCommand backupFrom(org.infinispan.commands.CommandsFactory factory,
                                                                                         org.infinispan.commands.functional.WriteOnlyManyCommand<K,V> command,
                                                                                         Collection<Object> keys)

backupFrom

public static <K,V,R> org.infinispan.commands.triangle.BackupWriteCommand backupFrom(org.infinispan.commands.CommandsFactory factory,
                                                                                                 org.infinispan.commands.functional.ReadWriteManyCommand<K,V,R> command,
                                                                                                 Collection<Object> keys)