Constructor and Description |
---|
MapKeyLoader(String mapName,
OperationService opService,
InternalPartitionService ps,
ExecutionService execService,
IFunction<Object,Data> serialize) |
Modifier and Type | Method and Description |
---|---|
void |
onKeyLoad(ExecutionCallback<Boolean> callback) |
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.
|
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)
public void setMapOperationProvider(MapOperationProvider operationProvider)
public void onKeyLoad(ExecutionCallback<Boolean> callback)
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.