com.hazelcast.map.impl

Class MapKeyLoader

java.lang.Object

com.hazelcast.map.impl.MapKeyLoader

public class MapKeyLoader
extends Object

Loads keys from a MapLoader and sends them to all partitions for loading

Constructor Summary

Constructors

Constructor and Description
MapKeyLoader(String mapName, OperationService opService, IPartitionService ps, ClusterService clusterService, ExecutionService execService, IFunction<Object,Data> serialize)

Method Summary

Modifier and Type	Method and Description
boolean	isKeyLoadFinished()
void	promoteToLoadedOnMigration()
Future<?>	sendKeys(MapStoreContext mapStoreContext, boolean replaceExistingValues) Sends keys to all partitions in batches.
void	setHasBackup(boolean hasBackup)
void	setMapOperationProvider(MapOperationProvider operationProvider)
void	setMaxBatch(int maxBatch)
void	setMaxSize(int maxSize)
boolean	shouldDoInitialLoad()
Future	startInitialLoad(MapStoreContext mapStoreContext, int partitionId)
Future<?>	startLoading(MapStoreContext mapStoreContext, boolean replaceExistingValues)
void	trackLoading(boolean lastBatch, Throwable exception)
Future	triggerLoading() Check if loaded on SENDER partition.
void	triggerLoadingWithDelay() Triggers key loading on SENDER if it hadn't started.

Methods inherited from class java.lang.Object

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

Constructor Detail

MapKeyLoader

public MapKeyLoader(String mapName,
                    OperationService opService,
                    IPartitionService ps,
                    ClusterService clusterService,
                    ExecutionService execService,
                    IFunction<Object,Data> serialize)

Method Detail

startInitialLoad

public Future startInitialLoad(MapStoreContext mapStoreContext,
                               int partitionId)

sendKeys

public Future<?> sendKeys(MapStoreContext mapStoreContext,
                          boolean replaceExistingValues)

Sends keys to all partitions in batches.

triggerLoading

public Future triggerLoading()

Check if loaded on SENDER partition. Triggers key loading if it hadn't started

startLoading

public Future<?> startLoading(MapStoreContext mapStoreContext,
                              boolean replaceExistingValues)

trackLoading

public void trackLoading(boolean lastBatch,
                         Throwable exception)

triggerLoadingWithDelay

public void triggerLoadingWithDelay()

Triggers key loading on SENDER if it hadn't started. Delays triggering if invoked multiple times.

shouldDoInitialLoad

public boolean shouldDoInitialLoad()

setMaxBatch

public void setMaxBatch(int maxBatch)

setMaxSize

public void setMaxSize(int maxSize)

setHasBackup

public void setHasBackup(boolean hasBackup)

setMapOperationProvider

public void setMapOperationProvider(MapOperationProvider operationProvider)

isKeyLoadFinished

public boolean isKeyLoadFinished()

promoteToLoadedOnMigration

public void promoteToLoadedOnMigration()