Package com.gigaspaces.internal.remoting.routing.partitioned

Interface ScatterGatherRemoteOperationRequest<TResult extends RemoteOperationResult>

All Superinterfaces:

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

All Known Implementing Classes:

ReadTakeEntriesByIdsSpaceOperationRequest, RegisterLocalViewSpaceOperationRequest, SpaceScatterGatherOperationRequest, UnregisterLocalViewSpaceOperationRequest, UpdateLeasesSpaceOperationRequest, WriteEntriesSpaceOperationRequest

public interface ScatterGatherRemoteOperationRequest<TResult extends RemoteOperationResult>
extends RemoteOperationRequest<TResult>

Since:

9.0.0

Author:

Niv Ingberg

Method Summary

Modifier and Type	Method	Description
ScatterGatherPartitionInfo	getPartitionInfo()
void	loadPartitionData(ScatterGatherRemoteOperationRequest<TResult> mainRequest)
boolean	processPartitionResult(ScatterGatherRemoteOperationRequest<TResult> partitionRequest, List<ScatterGatherRemoteOperationRequest<TResult>> previousRequests)
void	scatterIndexesToPartitions(ScatterGatherOperationFutureListener<TResult> scatterGatherCoordinator)

Methods inherited from interface java.io.Externalizable

readExternal, writeExternal

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

getLRMIMethodTrackingId

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

createCopy, createRemoteOperationResult, getAsyncFinalResult, getOperationCode, getPartitionedClusterExecutionType, getPartitionedClusterRoutingValue, getPreciseDistributionGroupingCode, getRemoteOperationResult, getSpaceContext, isBlockingOperation, isDedicatedPoolRequired, isDirectExecutionEnabled, processPartitionResult, processUnknownTypeException, requiresPartitionedPreciseDistribution, setRemoteOperationExecutionError, setRemoteOperationResult

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Method Details

scatterIndexesToPartitions

void scatterIndexesToPartitions(ScatterGatherOperationFutureListener<TResult> scatterGatherCoordinator)

loadPartitionData

void loadPartitionData(ScatterGatherRemoteOperationRequest<TResult> mainRequest)

getPartitionInfo

ScatterGatherPartitionInfo getPartitionInfo()

processPartitionResult

boolean processPartitionResult(ScatterGatherRemoteOperationRequest<TResult> partitionRequest,
 List<ScatterGatherRemoteOperationRequest<TResult>> previousRequests)