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() Returns true if there is no ongoing key loading and dispatching task on this map key loader.
void	promoteToLoadedOnMigration() Advances the state of the map key loader to State#LOADED
void	setHasBackup(boolean hasBackup) Sets if this map is configured with at least one backup.
void	setMapOperationProvider(MapOperationProvider operationProvider)
void	setMaxBatch(int maxBatch) Sets the maximum size of a batch of loaded keys sent to the partition owner for value loading.
void	setMaxSize(int maxSize) Sets the configured maximum entry count per node.
boolean	shouldDoInitialLoad() Returns true if the keys are not loaded yet, promoting this key loader and resetting the loading state if necessary in the process.
Future	startInitialLoad(MapStoreContext mapStoreContext, int partitionId) Triggers key loading on the map key loader with the Role#SENDER role.
Future<?>	startLoading(MapStoreContext mapStoreContext, boolean replaceExistingValues) Triggers key and value loading if there is no ongoing or completed key loading task, otherwise does nothing.
void	trackLoading(boolean lastBatch, Throwable exception) Advances the state of this map key loader and sets the keyLoadFinished result if the lastBatch is true.
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)

Triggers key loading on the map key loader with the Role#SENDER role.

Parameters:

mapStoreContext - the map store context for this map

partitionId - the partition ID of this map key loader

Returns:

a future representing pending completion of the key loading task

startLoading

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

Triggers key and value loading if there is no ongoing or completed key loading task, otherwise does nothing. The actual loading is done on a separate thread.

Parameters:

mapStoreContext - the map store context for this map

replaceExistingValues - if the existing entries for the loaded keys should be replaced

Returns:

a future representing pending completion of the key loading task

trackLoading

public void trackLoading(boolean lastBatch,
                         Throwable exception)

Advances the state of this map key loader and sets the keyLoadFinished result if the lastBatch is true.

If there was an exception during key loading, you may pass it as the exception paramter and it will be set as the result of the future.

Parameters:

lastBatch - if the last key batch was sent

exception - an exception that occurred during key loading

triggerLoadingWithDelay

public void triggerLoadingWithDelay()

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

shouldDoInitialLoad

public boolean shouldDoInitialLoad()

Returns true if the keys are not loaded yet, promoting this key loader and resetting the loading state if necessary in the process. If this gets invoked on SENDER BACKUP it means the SENDER died and SENDER BACKUP takes over.

setMaxBatch

public void setMaxBatch(int maxBatch)

Sets the maximum size of a batch of loaded keys sent to the partition owner for value loading.

Parameters:

maxBatch - the maximum size for a key batch

setMaxSize

public void setMaxSize(int maxSize)

Sets the configured maximum entry count per node.

Parameters:

maxSize - the maximum entry count per node

See Also:

MaxSizeConfig

setHasBackup

public void setHasBackup(boolean hasBackup)

Sets if this map is configured with at least one backup.

Parameters:

hasBackup - if this map is configured with at least one backup

setMapOperationProvider

public void setMapOperationProvider(MapOperationProvider operationProvider)

isKeyLoadFinished

public boolean isKeyLoadFinished()

Returns true if there is no ongoing key loading and dispatching task on this map key loader.

promoteToLoadedOnMigration

public void promoteToLoadedOnMigration()

Advances the state of the map key loader to State#LOADED