public class PostJoinMapOperation extends Operation implements IdentifiedDataSerializable, Versioned, TargetAware
| Modifier and Type | Class and Description |
|---|---|
static class |
PostJoinMapOperation.InterceptorInfo |
GENERIC_PARTITION_ID| Constructor and Description |
|---|
PostJoinMapOperation() |
| Modifier and Type | Method and Description |
|---|---|
void |
addMapInterceptors(MapContainer mapContainer) |
int |
getFactoryId()
Returns DataSerializableFactory factory ID for this class.
|
int |
getId()
Returns type identifier for this class.
|
String |
getServiceName() |
protected void |
readInternal(ObjectDataInput in) |
void |
run()
Runs the operation.
|
void |
setInfoList(List<AccumulatorInfo> infoList) |
void |
setTarget(Address address)
Provides the designated target member address to which the operation
will be sent.
|
protected void |
writeInternal(ObjectDataOutput out) |
afterRun, beforeRun, call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getResponse, getService, getWaitTimeout, isUrgent, logError, onExecutionFailure, onInvocationException, onSetCallId, readData, requiresExplicitServiceName, returnsResponse, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, toString, validatesTarget, writeDataclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitreadData, writeDatapublic String getServiceName()
getServiceName in class Operationpublic void addMapInterceptors(MapContainer mapContainer)
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()public void setInfoList(List<AccumulatorInfo> infoList)
protected void writeInternal(ObjectDataOutput out) throws IOException
writeInternal in class OperationIOExceptionprotected void readInternal(ObjectDataInput in) throws IOException
readInternal in class OperationIOExceptionpublic int getFactoryId()
IdentifiedDataSerializablegetFactoryId in interface IdentifiedDataSerializablepublic int getId()
IdentifiedDataSerializablegetId in interface IdentifiedDataSerializablepublic void setTarget(Address address)
TargetAwaresetTarget will be invoked on each retry with the
current target member's Address as argument
address is provided as target address
setTarget in interface TargetAwareaddress - target member's addressCopyright © 2019 Hazelcast, Inc.. All Rights Reserved.