org.infinispan.tasks

Class GlobalKeySetTask<K,V>

java.lang.Object

org.infinispan.tasks.GlobalKeySetTask<K,V>

All Implemented Interfaces:

Serializable, Callable<Set<K>>, DistributedCallable<K,V,Set<K>>

public class GlobalKeySetTask<K,V>
extends Object
implements DistributedCallable<K,V,Set<K>>, Serializable

GlobalKeySetTask is a DistributedCallable for obtaining all of the keys across a cluster.

Since:

5.3

Author:

Manik Surtani, Tristan Tarrant

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GlobalKeySetTask()

Method Summary

Methods

Modifier and Type	Method and Description
Set<K>	call()
static <K,V> Set<K>	getGlobalKeySet(Cache<K,V> cache)
void	setEnvironment(Cache<K,V> cache, Set<K> inputKeys) Invoked by execution environment after DistributedCallable has been migrated for execution to a specific Infinispan node.

Methods inherited from class java.lang.Object

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

Constructor Detail

GlobalKeySetTask

public GlobalKeySetTask()

Method Detail

call

public Set<K> call()
            throws Exception

Specified by:

call in interface Callable<Set<K>>

Throws:

Exception

setEnvironment

public void setEnvironment(Cache<K,V> cache,
                  Set<K> inputKeys)

Description copied from interface: DistributedCallable

Invoked by execution environment after DistributedCallable has been migrated for execution to a specific Infinispan node.

Specified by:

setEnvironment in interface DistributedCallable<K,V,Set<K>>

Parameters:

cache - cache whose keys are used as input data for this DistributedCallable task

inputKeys - keys used as input for this DistributedCallable task

getGlobalKeySet

public static <K,V> Set<K> getGlobalKeySet(Cache<K,V> cache)
                              throws InterruptedException,
                                     ExecutionException

Throws:

InterruptedException

ExecutionException