Class HotRodTargetMigrator
- java.lang.Object
-
- org.infinispan.persistence.remote.upgrade.HotRodTargetMigrator
-
- All Implemented Interfaces:
TargetMigrator
@MetaInfServices public class HotRodTargetMigrator extends Object implements TargetMigrator
-
-
Constructor Summary
Constructors Constructor Description HotRodTargetMigrator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
disconnectSource(Cache<Object,Object> cache)
Disconnects the target from the source.String
getName()
Returns the name of this migratorlong
synchronizeData(Cache<Object,Object> cache)
Performs the synchronization of data between source and targetlong
synchronizeData(Cache<Object,Object> cache, int readBatch, int threads)
Performs the synchronization of data between source and target
-
-
-
Method Detail
-
getName
public String getName()
Description copied from interface:TargetMigrator
Returns the name of this migrator- Specified by:
getName
in interfaceTargetMigrator
-
synchronizeData
public long synchronizeData(Cache<Object,Object> cache) throws CacheException
Description copied from interface:TargetMigrator
Performs the synchronization of data between source and target- Specified by:
synchronizeData
in interfaceTargetMigrator
- Throws:
CacheException
-
synchronizeData
public long synchronizeData(Cache<Object,Object> cache, int readBatch, int threads) throws CacheException
Description copied from interface:TargetMigrator
Performs the synchronization of data between source and target- Specified by:
synchronizeData
in interfaceTargetMigrator
- Throws:
CacheException
-
disconnectSource
public void disconnectSource(Cache<Object,Object> cache) throws CacheException
Description copied from interface:TargetMigrator
Disconnects the target from the source. This operation is the last step that must be performed after a rolling upgrade.- Specified by:
disconnectSource
in interfaceTargetMigrator
- Throws:
CacheException
-
-