com.gigaspaces.internal.remoting

Interface RemoteOperationRequest<TResult extends RemoteOperationResult>

All Superinterfaces:

LRMIMethodTrackingIdProvider

All Known Subinterfaces:

ScatterGatherRemoteOperationRequest<TResult>

All Known Implementing Classes:

AbortPreparedTransactionSpaceOperationRequest, AddEntryTypeIndexesSpaceOperationRequest, AggregateEntriesSpaceOperationRequest, ChangeEntriesSpaceOperationRequest, CommitPreparedTransactionSpaceOperationRequest, CountClearEntriesSpaceOperationRequest, ExecuteTaskSpaceOperationRequest, GetEntryTypeDescriptorSpaceOperationRequest, PrepareAndCommitTransactionSpaceOperationRequest, ReadTakeEntriesByIdsSpaceOperationRequest, ReadTakeEntriesSpaceOperationRequest, ReadTakeEntriesUidsSpaceOperationRequest, ReadTakeEntrySpaceOperationRequest, RegisterEntriesListenerSpaceOperationRequest, RegisterEntryTypeDescriptorSpaceOperationRequest, RegisterLocalViewSpaceOperationRequest, SpaceOperationRequest, SpaceScatterGatherOperationRequest, UnregisterLocalViewSpaceOperationRequest, UpdateLeaseSpaceOperationRequest, UpdateLeasesSpaceOperationRequest, WriteEntriesSpaceOperationRequest, WriteEntrySpaceOperationRequest

public interface RemoteOperationRequest<TResult extends RemoteOperationResult>
extends LRMIMethodTrackingIdProvider

Since:

9.0.0

Author:

Niv Ingberg

Method Summary

Modifier and Type	Method and Description
RemoteOperationRequest<TResult>	createCopy(int targetPartitionId)
TResult	createRemoteOperationResult()
Object	getAsyncFinalResult()
int	getOperationCode()
PartitionedClusterExecutionType	getPartitionedClusterExecutionType()
Object	getPartitionedClusterRoutingValue(PartitionedClusterRemoteOperationRouter router)
int	getPreciseDistributionGroupingCode()
TResult	getRemoteOperationResult()
boolean	isBlockingOperation()
boolean	isDedicatedPoolRequired()
boolean	processPartitionResult(TResult remoteOperationResult, List<TResult> previousResults, int numOfPartitions)
boolean	processUnknownTypeException(List<Integer> positions)
boolean	requiresPartitionedPreciseDistribution()
void	setRemoteOperationExecutionError(Exception error)
void	setRemoteOperationResult(TResult remoteOperationResult)

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

getLRMIMethodTrackingId

Method Detail

getOperationCode

int getOperationCode()

createRemoteOperationResult

TResult createRemoteOperationResult()

getRemoteOperationResult

TResult getRemoteOperationResult()

setRemoteOperationResult

void setRemoteOperationResult(TResult remoteOperationResult)

setRemoteOperationExecutionError

void setRemoteOperationExecutionError(Exception error)

getAsyncFinalResult

Object getAsyncFinalResult()
                    throws Exception

Throws:

Exception

isBlockingOperation

boolean isBlockingOperation()

processUnknownTypeException

boolean processUnknownTypeException(List<Integer> positions)

getPartitionedClusterExecutionType

PartitionedClusterExecutionType getPartitionedClusterExecutionType()

getPartitionedClusterRoutingValue

Object getPartitionedClusterRoutingValue(PartitionedClusterRemoteOperationRouter router)

requiresPartitionedPreciseDistribution

boolean requiresPartitionedPreciseDistribution()

getPreciseDistributionGroupingCode

int getPreciseDistributionGroupingCode()

createCopy

RemoteOperationRequest<TResult> createCopy(int targetPartitionId)

processPartitionResult

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

isDedicatedPoolRequired

boolean isDedicatedPoolRequired()