Package com.gigaspaces.internal.client.spaceproxy.operations

Class SpaceOperationRequest<TResult extends SpaceOperationResult>

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

AbortPreparedTransactionSpaceOperationRequest, AddEntryTypeIndexesSpaceOperationRequest, AggregateEntriesSpaceOperationRequest, ChangeEntriesSpaceOperationRequest, CommitPreparedTransactionSpaceOperationRequest, CountClearEntriesSpaceOperationRequest, ExecuteDurableTaskSpaceOperationRequest, ExecuteTaskSpaceOperationRequest, GetEntryTypeDescriptorSpaceOperationRequest, ListDurableTaskSpaceOperationRequest, PrepareAndCommitTransactionSpaceOperationRequest, ReadTakeEntriesSpaceOperationRequest, ReadTakeEntriesUidsSpaceOperationRequest, ReadTakeEntrySpaceOperationRequest, RegisterDurableTaskSpaceOperationRequest, RegisterEntriesListenerSpaceOperationRequest, RegisterEntryTypeDescriptorSpaceOperationRequest, SpaceScatterGatherOperationRequest, UnregisterDurableTaskSpaceOperationRequest, UpdateLeaseSpaceOperationRequest, WriteEntrySpaceOperationRequest

public abstract class SpaceOperationRequest<TResult extends SpaceOperationResult>
extends Object
implements RemoteOperationRequest<TResult>, Cloneable, SmartExternalizable, Textualizable

Since:

9.0.0

Author:

Niv Ingberg

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
SpaceOperationRequest()

Method Summary

Modifier and Type	Method	Description
void	afterOperationExecution(int partitionId)
boolean	beforeOperationExecution(boolean isEmbedded)
protected Object	clone()
RemoteOperationRequest<TResult>	createCopy(int targetPartitionId)
Object	getAsyncFinalResult()
int	getPreciseDistributionGroupingCode()
TResult	getRemoteOperationResult()
SpaceContext	getSpaceContext()
Transaction	getTransaction()
boolean	hasLockedResources()
boolean	isBlockingOperation()
boolean	isDedicatedPoolRequired()
boolean	isDirectExecutionEnabled()
boolean	processPartitionResult(TResult remoteOperationResult, List<TResult> previousResults, int numOfPartitions)
boolean	processUnknownTypeException(List<Integer> positions)
void	readExternal(ObjectInput in)
boolean	requiresPartitionedPreciseDistribution()
void	setRemoteOperationExecutionError(Exception error)
void	setRemoteOperationResult(TResult remoteOperationResult)
void	setSpaceContext(SpaceContext spaceContext)
boolean	supportsSecurity()
String	toString()
void	toText(Textualizer textualizer)
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.lrmi.nio.LRMIMethodTrackingIdProvider

getLRMIMethodTrackingId

Methods inherited from interface com.gigaspaces.internal.remoting.RemoteOperationRequest

createRemoteOperationResult, getOperationCode, getPartitionedClusterExecutionType, getPartitionedClusterRoutingValue

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Details

SpaceOperationRequest

public SpaceOperationRequest()

Method Details

toString

public String toString()

Overrides:

toString in class Object

toText

public void toText(Textualizer textualizer)

Specified by:

toText in interface Textualizable

getRemoteOperationResult

public TResult getRemoteOperationResult()

Specified by:

getRemoteOperationResult in interface RemoteOperationRequest<TResult extends SpaceOperationResult>

setRemoteOperationResult

public void setRemoteOperationResult(TResult remoteOperationResult)

Specified by:

setRemoteOperationResult in interface RemoteOperationRequest<TResult extends SpaceOperationResult>

setRemoteOperationExecutionError

public void setRemoteOperationExecutionError(Exception error)

Specified by:

setRemoteOperationExecutionError in interface RemoteOperationRequest<TResult extends SpaceOperationResult>

processPartitionResult

public boolean processPartitionResult(TResult remoteOperationResult,
 List<TResult> previousResults,
 int numOfPartitions)

Specified by:

processPartitionResult in interface RemoteOperationRequest<TResult extends SpaceOperationResult>

getAsyncFinalResult

public Object getAsyncFinalResult()
                           throws Exception

Specified by:

getAsyncFinalResult in interface RemoteOperationRequest<TResult extends SpaceOperationResult>

Throws:

Exception

getTransaction

public Transaction getTransaction()

isBlockingOperation

public boolean isBlockingOperation()

Specified by:

isBlockingOperation in interface RemoteOperationRequest<TResult extends SpaceOperationResult>

isDedicatedPoolRequired

public boolean isDedicatedPoolRequired()

Specified by:

isDedicatedPoolRequired in interface RemoteOperationRequest<TResult extends SpaceOperationResult>

isDirectExecutionEnabled

public boolean isDirectExecutionEnabled()

Specified by:

isDirectExecutionEnabled in interface RemoteOperationRequest<TResult extends SpaceOperationResult>

processUnknownTypeException

public boolean processUnknownTypeException(List<Integer> positions)

Specified by:

processUnknownTypeException in interface RemoteOperationRequest<TResult extends SpaceOperationResult>

setSpaceContext

public void setSpaceContext(SpaceContext spaceContext)

getSpaceContext

public SpaceContext getSpaceContext()

Specified by:

getSpaceContext in interface RemoteOperationRequest<TResult extends SpaceOperationResult>

createCopy

public RemoteOperationRequest<TResult> createCopy(int targetPartitionId)

Specified by:

createCopy in interface RemoteOperationRequest<TResult extends SpaceOperationResult>

clone

protected Object clone()

Overrides:

clone in class Object

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

beforeOperationExecution

public boolean beforeOperationExecution(boolean isEmbedded)

afterOperationExecution

public void afterOperationExecution(int partitionId)

hasLockedResources

public boolean hasLockedResources()

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<TResult extends SpaceOperationResult>

getPreciseDistributionGroupingCode

public int getPreciseDistributionGroupingCode()

Specified by:

getPreciseDistributionGroupingCode in interface RemoteOperationRequest<TResult extends SpaceOperationResult>

supportsSecurity

public boolean supportsSecurity()