Package org.infinispan.persistence.remote.upgrade

Class MigrationTask

java.lang.Object

org.infinispan.persistence.remote.upgrade.MigrationTask

All Implemented Interfaces:

Callable<Integer>, DistributedCallable<Object,Object,Integer>

public class MigrationTask
extends Object
implements DistributedCallable<Object,Object,Integer>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MigrationTask.Externalizer

Constructor Summary

Constructors

Constructor	Description
MigrationTask(Set<Integer> segments, int readBatch, int threads)

Method Summary

Modifier and Type	Method	Description
Integer	call()
void	setEnvironment(Cache<Object,Object> cache, Set<Object> 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

MigrationTask

public MigrationTask(Set<Integer> segments,
                     int readBatch,
                     int threads)

Method Detail

call

public Integer call()
             throws Exception

Specified by:

call in interface Callable<Integer>

Throws:

Exception

setEnvironment

public void setEnvironment(Cache<Object,Object> cache,
                           Set<Object> 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<Object,Object,Integer>

Parameters:

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

inputKeys - keys used as input for this DistributedCallable task