com.hazelcast.multimap.impl.operations
Class MultiMapOperation

java.lang.Object
  extended by com.hazelcast.spi.Operation
      extended by com.hazelcast.multimap.impl.operations.MultiMapOperation
All Implemented Interfaces:
DataSerializable, IdentifiedDataSerializable, RemotePropagatable<Operation>, PartitionAwareOperation
Direct Known Subclasses:
ClearBackupOperation, ClearOperation, ContainsEntryOperation, EntrySetOperation, KeySetOperation, MultiMapKeyBasedOperation, SizeOperation, ValuesOperation

public abstract class MultiMapOperation
extends Operation
implements PartitionAwareOperation, IdentifiedDataSerializable


Field Summary
protected  String name
           
protected  Object response
           
 
Constructor Summary
protected MultiMapOperation()
           
protected MultiMapOperation(String name)
           
 
Method Summary
 void afterRun()
           
 void beforeRun()
           
 int getAsyncBackupCount()
           
 int getFactoryId()
          Returns DataSerializableFactory factory id for this class.
 MultiMapContainer getOrCreateContainer()
           
 Object getResponse()
           
 String getServiceName()
           
 int getSyncBackupCount()
           
 MultiMapConfig.ValueCollectionType getValueCollectionType(MultiMapContainer container)
           
 boolean hasListener()
           
 boolean isBinary()
           
 void publishEvent(EntryEventType eventType, Data key, Object value)
           
protected  void readInternal(ObjectDataInput in)
           
 boolean returnsResponse()
           
 Data toData(Object obj)
           
 Object toObject(Object obj)
           
protected  void writeInternal(ObjectDataOutput out)
           
 
Methods inherited from class com.hazelcast.spi.Operation
getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getExecutorName, getInvocationTime, getLogger, getNodeEngine, getPartitionId, getReplicaIndex, getResponseHandler, getService, getWaitTimeout, isUrgent, logError, onException, readData, run, setCallerUuid, setExecutorName, setNodeEngine, setPartitionId, setReplicaIndex, setResponseHandler, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, validatesTarget, writeData
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface com.hazelcast.spi.PartitionAwareOperation
getPartitionId
 
Methods inherited from interface com.hazelcast.nio.serialization.IdentifiedDataSerializable
getId
 
Methods inherited from interface com.hazelcast.nio.serialization.DataSerializable
readData, writeData
 

Field Detail

name

protected String name

response

protected transient Object response
Constructor Detail

MultiMapOperation

protected MultiMapOperation()

MultiMapOperation

protected MultiMapOperation(String name)
Method Detail

getResponse

public final Object getResponse()
Specified by:
getResponse in class Operation

getServiceName

public final String getServiceName()
Overrides:
getServiceName in class Operation

afterRun

public void afterRun()
              throws Exception
Specified by:
afterRun in class Operation
Throws:
Exception

beforeRun

public void beforeRun()
               throws Exception
Specified by:
beforeRun in class Operation
Throws:
Exception

returnsResponse

public boolean returnsResponse()
Specified by:
returnsResponse in interface RemotePropagatable<Operation>
Specified by:
returnsResponse in class Operation

hasListener

public final boolean hasListener()

publishEvent

public final void publishEvent(EntryEventType eventType,
                               Data key,
                               Object value)

toObject

public final Object toObject(Object obj)

toData

public final Data toData(Object obj)

getOrCreateContainer

public final MultiMapContainer getOrCreateContainer()

getValueCollectionType

public final MultiMapConfig.ValueCollectionType getValueCollectionType(MultiMapContainer container)

isBinary

public final boolean isBinary()

getSyncBackupCount

public final int getSyncBackupCount()

getAsyncBackupCount

public final int getAsyncBackupCount()

writeInternal

protected void writeInternal(ObjectDataOutput out)
                      throws IOException
Specified by:
writeInternal in class Operation
Throws:
IOException

readInternal

protected void readInternal(ObjectDataInput in)
                     throws IOException
Specified by:
readInternal in class Operation
Throws:
IOException

getFactoryId

public int getFactoryId()
Description copied from interface: IdentifiedDataSerializable
Returns DataSerializableFactory factory id for this class.

Specified by:
getFactoryId in interface IdentifiedDataSerializable
Returns:
factory id


Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.