com.hazelcast.map.impl
Constructor and Description |
---|
MapKeyLoader(String mapName,
OperationService opService,
InternalPartitionService ps,
ExecutionService execService,
IFunction<Object,Data> serialize) |
Modifier and Type | Method and Description |
---|---|
Future<?> |
sendKeys(MapStoreContext mapStoreContext,
boolean replaceExistingValues)
Sends keys to all partitions in batches.
|
void |
setHasBackup(boolean hasBackup) |
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.
|
public MapKeyLoader(String mapName, OperationService opService, InternalPartitionService ps, ExecutionService execService, IFunction<Object,Data> serialize)
public Future startInitialLoad(MapStoreContext mapStoreContext, int partitionId)
public Future<?> sendKeys(MapStoreContext mapStoreContext, boolean replaceExistingValues)
public Future triggerLoading()
public Future<?> startLoading(MapStoreContext mapStoreContext, boolean replaceExistingValues)
public void trackLoading(boolean lastBatch, Throwable exception)
public void triggerLoadingWithDelay()
public boolean shouldDoInitialLoad()
public void setMaxBatch(int maxBatch)
public void setMaxSize(int maxSize)
public void setHasBackup(boolean hasBackup)
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.