Interface RemoteOperationRequest<TResult extends RemoteOperationResult>

All Superinterfaces:

Externalizable, LRMIMethodTrackingIdProvider, Serializable, SmartExternalizable

All Known Subinterfaces:

ScatterGatherRemoteOperationRequest<TResult>

All Known Implementing Classes:

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

public interface RemoteOperationRequest<TResult extends RemoteOperationResult>
extends LRMIMethodTrackingIdProvider, SmartExternalizable

Since:

9.0.0

Author:

Niv Ingberg

Method Summary

Modifier and Type	Method	Description
RemoteOperationRequest<TResult>	createCopy(int targetPartitionId)
TResult	createRemoteOperationResult()
Object	getAsyncFinalResult()
int	getOperationCode()
PartitionedClusterExecutionType	getPartitionedClusterExecutionType()
Object	getPartitionedClusterRoutingValue(PartitionedClusterRemoteOperationRouter router)
int	getPreciseDistributionGroupingCode()
TResult	getRemoteOperationResult()
SpaceContext	getSpaceContext()
boolean	isBlockingOperation()
boolean	isDedicatedPoolRequired()
boolean	isDirectExecutionEnabled()
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 Externalizable

readExternal, writeExternal

Methods inherited from interface LRMIMethodTrackingIdProvider

getLRMIMethodTrackingId

Methods inherited from interface SmartExternalizable

enabledSmartExternalizableWithReference

Method Details

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()

getSpaceContext

SpaceContext getSpaceContext()

createCopy

RemoteOperationRequest<TResult> createCopy(int targetPartitionId)

processPartitionResult

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

isDedicatedPoolRequired

boolean isDedicatedPoolRequired()

isDirectExecutionEnabled

boolean isDirectExecutionEnabled()