com.gigaspaces.internal.client.spaceproxy.operations

Class ReadTakeEntrySpaceOperationRequest

java.lang.Object

com.gigaspaces.internal.client.spaceproxy.operations.SpaceOperationRequest<ReadTakeEntrySpaceOperationResult>

com.gigaspaces.internal.client.spaceproxy.operations.ReadTakeEntrySpaceOperationRequest

All Implemented Interfaces:

RemoteOperationRequest<ReadTakeEntrySpaceOperationResult>, Textualizable, LRMIMethodTrackingIdProvider, Externalizable, Serializable, Cloneable

public class ReadTakeEntrySpaceOperationRequest
extends SpaceOperationRequest<ReadTakeEntrySpaceOperationResult>

Since:

9.0.0

Author:

anna

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ReadTakeEntrySpaceOperationRequest() Required for Externalizable
ReadTakeEntrySpaceOperationRequest(ITemplatePacket templatePacket, Transaction txn, boolean isTake, boolean ifExists, long timeout, int modifiers, boolean returnOnlyUid, ISpaceProxyTypeManager typeManager, boolean returnPacket, Object query)
ReadTakeEntrySpaceOperationRequest(ITemplatePacket templatePacket, Transaction txn, boolean isTake, boolean ifExists, long timeout, int modifiers, boolean returnOnlyUid, Object query)

Method Summary

Modifier and Type	Method and Description
void	afterOperationExecution(int partitionId)
RemoteOperationRequest<ReadTakeEntrySpaceOperationResult>	createCopy(int targetPartitionId)
ReadTakeEntrySpaceOperationResult	createRemoteOperationResult()
Object	getAsyncFinalResult()
ExplainPlan	getExplainPlan()
IEntryPacket	getFinalResult()
String	getLRMIMethodTrackingId()
int	getModifiers()
int	getOperationCode()
PartitionedClusterExecutionType	getPartitionedClusterExecutionType()
Object	getPartitionedClusterRoutingValue(PartitionedClusterRemoteOperationRouter router)
int	getPreciseDistributionGroupingCode()
ITemplatePacket	getTemplatePacket()
long	getTimeout()
Transaction	getTransaction()
boolean	hasLockedResources()
boolean	isBlockingOperation()
boolean	isIfExists()
boolean	isReturnOnlyUid()
boolean	isTake()
boolean	processPartitionResult(ReadTakeEntrySpaceOperationResult partitionResult, List<ReadTakeEntrySpaceOperationResult> previousResults, int numOfPartitions)
boolean	processUnknownTypeException(List<Integer> positions)
void	readExternal(ObjectInput in)
boolean	requiresPartitionedPreciseDistribution()
void	toText(Textualizer textualizer)
void	writeExternal(ObjectOutput out)

Methods inherited from class com.gigaspaces.internal.client.spaceproxy.operations.SpaceOperationRequest

beforeOperationExecution, clone, getRemoteOperationResult, getSpaceContext, isDedicatedPoolRequired, setRemoteOperationExecutionError, setRemoteOperationResult, setSpaceContext, supportsSecurity, toString

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ReadTakeEntrySpaceOperationRequest

public ReadTakeEntrySpaceOperationRequest()

Required for Externalizable

ReadTakeEntrySpaceOperationRequest

public ReadTakeEntrySpaceOperationRequest(ITemplatePacket templatePacket,
                                          Transaction txn,
                                          boolean isTake,
                                          boolean ifExists,
                                          long timeout,
                                          int modifiers,
                                          boolean returnOnlyUid,
                                          Object query)

ReadTakeEntrySpaceOperationRequest

public ReadTakeEntrySpaceOperationRequest(ITemplatePacket templatePacket,
                                          Transaction txn,
                                          boolean isTake,
                                          boolean ifExists,
                                          long timeout,
                                          int modifiers,
                                          boolean returnOnlyUid,
                                          ISpaceProxyTypeManager typeManager,
                                          boolean returnPacket,
                                          Object query)

Method Detail

toText

public void toText(Textualizer textualizer)

Specified by:

toText in interface Textualizable

Overrides:

toText in class SpaceOperationRequest<ReadTakeEntrySpaceOperationResult>

getOperationCode

public int getOperationCode()

createRemoteOperationResult

public ReadTakeEntrySpaceOperationResult createRemoteOperationResult()

getPartitionedClusterExecutionType

public PartitionedClusterExecutionType getPartitionedClusterExecutionType()

getPartitionedClusterRoutingValue

public Object getPartitionedClusterRoutingValue(PartitionedClusterRemoteOperationRouter router)

getTemplatePacket

public ITemplatePacket getTemplatePacket()

getModifiers

public int getModifiers()

getTimeout

public long getTimeout()

getTransaction

public Transaction getTransaction()

Overrides:

getTransaction in class SpaceOperationRequest<ReadTakeEntrySpaceOperationResult>

isBlockingOperation

public boolean isBlockingOperation()

Specified by:

isBlockingOperation in interface RemoteOperationRequest<ReadTakeEntrySpaceOperationResult>

Overrides:

isBlockingOperation in class SpaceOperationRequest<ReadTakeEntrySpaceOperationResult>

isTake

public boolean isTake()

isIfExists

public boolean isIfExists()

isReturnOnlyUid

public boolean isReturnOnlyUid()

processUnknownTypeException

public boolean processUnknownTypeException(List<Integer> positions)

Specified by:

processUnknownTypeException in interface RemoteOperationRequest<ReadTakeEntrySpaceOperationResult>

Overrides:

processUnknownTypeException in class SpaceOperationRequest<ReadTakeEntrySpaceOperationResult>

processPartitionResult

public boolean processPartitionResult(ReadTakeEntrySpaceOperationResult partitionResult,
                                      List<ReadTakeEntrySpaceOperationResult> previousResults,
                                      int numOfPartitions)

Specified by:

processPartitionResult in interface RemoteOperationRequest<ReadTakeEntrySpaceOperationResult>

Overrides:

processPartitionResult in class SpaceOperationRequest<ReadTakeEntrySpaceOperationResult>

getFinalResult

public IEntryPacket getFinalResult()
                            throws RemoteException,
                                   TransactionException,
                                   InterruptedException,
                                   UnusableEntryException

Throws:

RemoteException

TransactionException

InterruptedException

UnusableEntryException

getAsyncFinalResult

public Object getAsyncFinalResult()
                           throws Exception

Specified by:

getAsyncFinalResult in interface RemoteOperationRequest<ReadTakeEntrySpaceOperationResult>

Overrides:

getAsyncFinalResult in class SpaceOperationRequest<ReadTakeEntrySpaceOperationResult>

Throws:

Exception

getLRMIMethodTrackingId

public String getLRMIMethodTrackingId()

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class SpaceOperationRequest<ReadTakeEntrySpaceOperationResult>

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class SpaceOperationRequest<ReadTakeEntrySpaceOperationResult>

Throws:

IOException

ClassNotFoundException

createCopy

public RemoteOperationRequest<ReadTakeEntrySpaceOperationResult> createCopy(int targetPartitionId)

Specified by:

createCopy in interface RemoteOperationRequest<ReadTakeEntrySpaceOperationResult>

Overrides:

createCopy in class SpaceOperationRequest<ReadTakeEntrySpaceOperationResult>

hasLockedResources

public boolean hasLockedResources()

Overrides:

hasLockedResources in class SpaceOperationRequest<ReadTakeEntrySpaceOperationResult>

Returns:

true if the request execution caused entries to be locked under transaction, false otherwise.

requiresPartitionedPreciseDistribution

public boolean requiresPartitionedPreciseDistribution()

Specified by:

requiresPartitionedPreciseDistribution in interface RemoteOperationRequest<ReadTakeEntrySpaceOperationResult>

Overrides:

requiresPartitionedPreciseDistribution in class SpaceOperationRequest<ReadTakeEntrySpaceOperationResult>

getPreciseDistributionGroupingCode

public int getPreciseDistributionGroupingCode()

Specified by:

getPreciseDistributionGroupingCode in interface RemoteOperationRequest<ReadTakeEntrySpaceOperationResult>

Overrides:

getPreciseDistributionGroupingCode in class SpaceOperationRequest<ReadTakeEntrySpaceOperationResult>

afterOperationExecution

public void afterOperationExecution(int partitionId)

Overrides:

afterOperationExecution in class SpaceOperationRequest<ReadTakeEntrySpaceOperationResult>

getExplainPlan

public ExplainPlan getExplainPlan()