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

Class ExecuteTaskSpaceOperationRequest

java.lang.Object

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

com.gigaspaces.internal.client.spaceproxy.operations.ExecuteTaskSpaceOperationRequest

All Implemented Interfaces:

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

public class ExecuteTaskSpaceOperationRequest
extends SpaceOperationRequest<ExecuteTaskSpaceOperationResult>

Since:

9.0.0

Author:

Niv Ingberg

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ExecuteTaskSpaceOperationRequest()	Required for Externalizable
ExecuteTaskSpaceOperationRequest(SpaceTask<?> task, Transaction txn, Object routingValue, Map<String,byte[]> classes)

Method Summary

Modifier and Type	Method	Description
void	afterOperationExecution(int partitionId)
boolean	beforeOperationExecution(boolean isEmbedded)
Map<String,byte[]>	classes()
ExecuteTaskSpaceOperationResult	createRemoteOperationResult()
Object	getAsyncFinalResult()
String	getLRMIMethodTrackingId()
int	getOperationCode()
PartitionedClusterExecutionType	getPartitionedClusterExecutionType()
Object	getPartitionedClusterRoutingValue(PartitionedClusterRemoteOperationRouter router)
SpaceTask<?>	getTask()
Transaction	getTransaction()
boolean	isDedicatedPoolRequired()
boolean	processPartitionResult(ExecuteTaskSpaceOperationResult remoteOperationResult, List<ExecuteTaskSpaceOperationResult> previousResults, int numOfPartitions)
void	readExternal(ObjectInput in)
void	setClasses(Map<String,byte[]> classes)
void	setTask(SpaceTask<?> task)
void	toText(Textualizer textualizer)
void	writeExternal(ObjectOutput out)

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

clone, createCopy, getPreciseDistributionGroupingCode, getRemoteOperationResult, getSpaceContext, hasLockedResources, isBlockingOperation, isDirectExecutionEnabled, processUnknownTypeException, requiresPartitionedPreciseDistribution, 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 Details

ExecuteTaskSpaceOperationRequest

public ExecuteTaskSpaceOperationRequest()

Required for Externalizable

ExecuteTaskSpaceOperationRequest

public ExecuteTaskSpaceOperationRequest(SpaceTask<?> task,
 Transaction txn,
 Object routingValue,
 Map<String,byte[]> classes)

Method Details

toText

public void toText(Textualizer textualizer)

Specified by:

toText in interface Textualizable

Overrides:

toText in class SpaceOperationRequest<ExecuteTaskSpaceOperationResult>

classes

public Map<String,byte[]> classes()

setClasses

public void setClasses(Map<String,byte[]> classes)

setTask

public void setTask(SpaceTask<?> task)

getTask

public SpaceTask<?> getTask()

getTransaction

public Transaction getTransaction()

Overrides:

getTransaction in class SpaceOperationRequest<ExecuteTaskSpaceOperationResult>

getOperationCode

public int getOperationCode()

createRemoteOperationResult

public ExecuteTaskSpaceOperationResult createRemoteOperationResult()

isDedicatedPoolRequired

public boolean isDedicatedPoolRequired()

Specified by:

isDedicatedPoolRequired in interface RemoteOperationRequest<ExecuteTaskSpaceOperationResult>

Overrides:

isDedicatedPoolRequired in class SpaceOperationRequest<ExecuteTaskSpaceOperationResult>

getPartitionedClusterExecutionType

public PartitionedClusterExecutionType getPartitionedClusterExecutionType()

getPartitionedClusterRoutingValue

public Object getPartitionedClusterRoutingValue(PartitionedClusterRemoteOperationRouter router)

processPartitionResult

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

Specified by:

processPartitionResult in interface RemoteOperationRequest<ExecuteTaskSpaceOperationResult>

Overrides:

processPartitionResult in class SpaceOperationRequest<ExecuteTaskSpaceOperationResult>

getAsyncFinalResult

public Object getAsyncFinalResult()
                           throws Exception

Specified by:

getAsyncFinalResult in interface RemoteOperationRequest<ExecuteTaskSpaceOperationResult>

Overrides:

getAsyncFinalResult in class SpaceOperationRequest<ExecuteTaskSpaceOperationResult>

Throws:

Exception

beforeOperationExecution

public boolean beforeOperationExecution(boolean isEmbedded)

Overrides:

beforeOperationExecution in class SpaceOperationRequest<ExecuteTaskSpaceOperationResult>

afterOperationExecution

public void afterOperationExecution(int partitionId)

Overrides:

afterOperationExecution in class SpaceOperationRequest<ExecuteTaskSpaceOperationResult>

getLRMIMethodTrackingId

public String getLRMIMethodTrackingId()

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class SpaceOperationRequest<ExecuteTaskSpaceOperationResult>

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class SpaceOperationRequest<ExecuteTaskSpaceOperationResult>

Throws:

IOException

ClassNotFoundException