public class MultipleEntryBackupOperation extends MapOperation implements BackupOperation
Modifier and Type | Field and Description |
---|---|
protected EntryBackupProcessor |
backupProcessor |
protected MapEntries |
responses |
protected List<WanEventHolder> |
wanEventList |
createRecordStoreOnDemand, mapContainer, mapEventPublisher, mapService, mapServiceContext, recordStore
name
GENERIC_PARTITION_ID
Constructor and Description |
---|
MultipleEntryBackupOperation() |
MultipleEntryBackupOperation(String name,
Set<Data> keys,
EntryBackupProcessor backupProcessor) |
Modifier and Type | Method and Description |
---|---|
int |
getId()
Returns type identifier for this class.
|
protected Predicate |
getPredicate() |
Object |
getResponse() |
protected void |
readInternal(ObjectDataInput in) |
void |
run() |
protected void |
setWanEventList(List<WanEventHolder> wanEventList) |
protected void |
writeInternal(ObjectDataOutput out) |
beforeRun, evict, getFactoryId, getServiceName, getServiceNamespace, getThreadId, innerBeforeRun, invalidateAllKeysInNearCaches, invalidateNearCache, invalidateNearCache, isPostProcessing, setMapContainer, setMapService, setThreadId
getName, toString
afterRun, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getService, getWaitTimeout, isUrgent, logError, onExecutionFailure, onInvocationException, onSetCallId, readData, returnsResponse, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, validatesTarget, writeData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getPartitionId
readData, writeData
protected MapEntries responses
protected EntryBackupProcessor backupProcessor
protected List<WanEventHolder> wanEventList
public MultipleEntryBackupOperation()
public MultipleEntryBackupOperation(String name, Set<Data> keys, EntryBackupProcessor backupProcessor)
protected void readInternal(ObjectDataInput in) throws IOException
IOException
protected void writeInternal(ObjectDataOutput out) throws IOException
IOException
public Object getResponse()
getResponse
in class Operation
public int getId()
IdentifiedDataSerializable
getId
in interface IdentifiedDataSerializable
protected Predicate getPredicate()
protected void setWanEventList(List<WanEventHolder> wanEventList)
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.