public class MultipleEntryBackupOperation extends MapOperation implements BackupOperation
createRecordStoreOnDemand, disableWanReplicationEvent, mapContainer, mapEventPublisher, mapService, mapServiceContext, recordStorenameGENERIC_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()
Called if and only if
Operation.returnsResponse() returned true,
shortly after Operation.run() returns. |
protected void |
readInternal(ObjectDataInput in) |
void |
run()
Runs the operation.
|
protected void |
writeInternal(ObjectDataOutput out) |
beforeRun, canThisOpGenerateWANEvent, evict, getCallerProvenance, getFactoryId, getServiceName, getServiceNamespace, getThreadId, innerBeforeRun, invalidateAllKeysInNearCaches, invalidateNearCache, invalidateNearCache, isPostProcessing, publishLoadAsWanUpdate, publishWanRemove, publishWanUpdate, setMapContainer, setMapService, setThreadIdgetName, toStringafterRun, call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getService, getWaitTimeout, isUrgent, logError, onExecutionFailure, onInvocationException, onSetCallId, readData, requiresExplicitServiceName, returnsResponse, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, validatesTarget, writeDataclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetPartitionIdreadData, writeDatapublic MultipleEntryBackupOperation()
public MultipleEntryBackupOperation(String name, Set<Data> keys, EntryBackupProcessor backupProcessor)
public void run()
throws Exception
OperationOperation.run() or Operation.call() method should be implemented; not both.
Runs after wait-support, supposed to do actual operationrun in class OperationExceptionOperation.call()protected void readInternal(ObjectDataInput in) throws IOException
readInternal in class AbstractNamedOperationIOExceptionprotected void writeInternal(ObjectDataOutput out) throws IOException
writeInternal in class AbstractNamedOperationIOExceptionpublic Object getResponse()
OperationOperation.returnsResponse() returned true,
shortly after Operation.run() returns.getResponse in class Operationpublic int getId()
IdentifiedDataSerializablegetId in interface IdentifiedDataSerializableprotected Predicate getPredicate()
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.