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

MapKeyLoader(String mapName, OperationService opService, InternalPartitionService ps, ExecutionService execService, IFunction<Object,Data> serialize)

Method Summary

Future<?>	sendKeys(MapStoreContext mapStoreContext, boolean replaceExistingValues) Sends keys to all partitions in batches.
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)
Future	triggerLoading() Check if loaded on SENDER partition.

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,
                    InternalPartitionService ps,
                    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

Parameters:

partitionId -

startLoading

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

trackLoading

public void trackLoading(boolean lastBatch)

shouldDoInitialLoad

public boolean shouldDoInitialLoad()

setMaxBatch

public void setMaxBatch(int maxBatch)

setMaxSize

public void setMaxSize(int maxSize)