com.gigaspaces.internal.client.spaceproxy.operations

Class ReadTakeEntriesSpaceOperationRequest

java.lang.Object

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

com.gigaspaces.internal.client.spaceproxy.operations.ReadTakeEntriesSpaceOperationRequest

All Implemented Interfaces:

RemoteOperationRequest<ReadTakeEntriesSpaceOperationResult>, Textualizable, LRMIMethodTrackingIdProvider, SmartExternalizable, Externalizable, Serializable, Cloneable

public class ReadTakeEntriesSpaceOperationRequest
extends SpaceOperationRequest<ReadTakeEntriesSpaceOperationResult>

Since:

9.0

Author:

idan

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ReadTakeEntriesSpaceOperationRequest() Required for Externalizable.
ReadTakeEntriesSpaceOperationRequest(ITemplatePacket templatePacket, Transaction transaction, boolean isTake, int modifiers, int maxResults, int minResultsToWaitFor, long timeout, boolean ifExist, Object query)

Method Summary

Modifier and Type	Method and Description
void	afterOperationExecution(int partitionId)
boolean	beforeOperationExecution(boolean isEmbedded)
RemoteOperationRequest<ReadTakeEntriesSpaceOperationResult>	createCopy(int targetPartitionId)
ReadTakeEntriesSpaceOperationResult	createRemoteOperationResult()
IEntryPacket[]	getFinalResult()
List<ReplicationLevel>	getLevels()
String	getLRMIMethodTrackingId()
int	getMaxResults()
int	getMinResultsToWaitFor()
int	getModifiers()
int	getOperationCode()
PartitionedClusterExecutionType	getPartitionedClusterExecutionType()
Object	getPartitionedClusterRoutingValue(PartitionedClusterRemoteOperationRouter router)
int	getPreciseDistributionGroupingCode()
ITemplatePacket	getTemplatePacket()
long	getTimeOut()
Transaction	getTransaction()
boolean	hasLockedResources()
boolean	isDirectExecutionEnabled()
boolean	isIfExist()
boolean	isTake()
boolean	processPartitionResult(ReadTakeEntriesSpaceOperationResult remoteOperationResult, List<ReadTakeEntriesSpaceOperationResult> previousResults, int numberOfPartitions)
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

clone, getAsyncFinalResult, getRemoteOperationResult, getSpaceContext, isBlockingOperation, isDedicatedPoolRequired, setRemoteOperationExecutionError, setRemoteOperationResult, setSpaceContext, supportsSecurity, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Detail

ReadTakeEntriesSpaceOperationRequest

public ReadTakeEntriesSpaceOperationRequest()

Required for Externalizable.

ReadTakeEntriesSpaceOperationRequest

public ReadTakeEntriesSpaceOperationRequest(ITemplatePacket templatePacket,
                                            Transaction transaction,
                                            boolean isTake,
                                            int modifiers,
                                            int maxResults,
                                            int minResultsToWaitFor,
                                            long timeout,
                                            boolean ifExist,
                                            Object query)

Method Detail

toText

public void toText(Textualizer textualizer)

Specified by:

toText in interface Textualizable

Overrides:

toText in class SpaceOperationRequest<ReadTakeEntriesSpaceOperationResult>

getOperationCode

public int getOperationCode()

createRemoteOperationResult

public ReadTakeEntriesSpaceOperationResult createRemoteOperationResult()

getPartitionedClusterExecutionType

public PartitionedClusterExecutionType getPartitionedClusterExecutionType()

processPartitionResult

public boolean processPartitionResult(ReadTakeEntriesSpaceOperationResult remoteOperationResult,
                                      List<ReadTakeEntriesSpaceOperationResult> previousResults,
                                      int numberOfPartitions)

Specified by:

processPartitionResult in interface RemoteOperationRequest<ReadTakeEntriesSpaceOperationResult>

Overrides:

processPartitionResult in class SpaceOperationRequest<ReadTakeEntriesSpaceOperationResult>

getFinalResult

public IEntryPacket[] getFinalResult()
                              throws RemoteException,
                                     TransactionException,
                                     UnusableEntryException

Throws:

RemoteException

TransactionException

UnusableEntryException

getPartitionedClusterRoutingValue

public Object getPartitionedClusterRoutingValue(PartitionedClusterRemoteOperationRouter router)

processUnknownTypeException

public boolean processUnknownTypeException(List<Integer> positions)

Specified by:

processUnknownTypeException in interface RemoteOperationRequest<ReadTakeEntriesSpaceOperationResult>

Overrides:

processUnknownTypeException in class SpaceOperationRequest<ReadTakeEntriesSpaceOperationResult>

getTransaction

public Transaction getTransaction()

Overrides:

getTransaction in class SpaceOperationRequest<ReadTakeEntriesSpaceOperationResult>

getTemplatePacket

public ITemplatePacket getTemplatePacket()

isTake

public boolean isTake()

getMaxResults

public int getMaxResults()

getModifiers

public int getModifiers()

isDirectExecutionEnabled

public boolean isDirectExecutionEnabled()

Specified by:

isDirectExecutionEnabled in interface RemoteOperationRequest<ReadTakeEntriesSpaceOperationResult>

Overrides:

isDirectExecutionEnabled in class SpaceOperationRequest<ReadTakeEntriesSpaceOperationResult>

getMinResultsToWaitFor

public int getMinResultsToWaitFor()

getTimeOut

public long getTimeOut()

isIfExist

public boolean isIfExist()

getLRMIMethodTrackingId

public String getLRMIMethodTrackingId()

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class SpaceOperationRequest<ReadTakeEntriesSpaceOperationResult>

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class SpaceOperationRequest<ReadTakeEntriesSpaceOperationResult>

Throws:

IOException

ClassNotFoundException

createCopy

public RemoteOperationRequest<ReadTakeEntriesSpaceOperationResult> createCopy(int targetPartitionId)

Specified by:

createCopy in interface RemoteOperationRequest<ReadTakeEntriesSpaceOperationResult>

Overrides:

createCopy in class SpaceOperationRequest<ReadTakeEntriesSpaceOperationResult>

hasLockedResources

public boolean hasLockedResources()

Overrides:

hasLockedResources in class SpaceOperationRequest<ReadTakeEntriesSpaceOperationResult>

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<ReadTakeEntriesSpaceOperationResult>

Overrides:

requiresPartitionedPreciseDistribution in class SpaceOperationRequest<ReadTakeEntriesSpaceOperationResult>

getPreciseDistributionGroupingCode

public int getPreciseDistributionGroupingCode()

Specified by:

getPreciseDistributionGroupingCode in interface RemoteOperationRequest<ReadTakeEntriesSpaceOperationResult>

Overrides:

getPreciseDistributionGroupingCode in class SpaceOperationRequest<ReadTakeEntriesSpaceOperationResult>

getLevels

public List<ReplicationLevel> getLevels()

afterOperationExecution

public void afterOperationExecution(int partitionId)

Overrides:

afterOperationExecution in class SpaceOperationRequest<ReadTakeEntriesSpaceOperationResult>

beforeOperationExecution

public boolean beforeOperationExecution(boolean isEmbedded)

Overrides:

beforeOperationExecution in class SpaceOperationRequest<ReadTakeEntriesSpaceOperationResult>