com.gigaspaces.internal.client.spaceproxy.operations

Class SpaceScatterGatherOperationRequest<TResult extends SpaceOperationResult>

java.lang.Object

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

ReadTakeEntriesByIdsSpaceOperationRequest, RegisterLocalViewSpaceOperationRequest, UnregisterLocalViewSpaceOperationRequest, UpdateLeasesSpaceOperationRequest, WriteEntriesSpaceOperationRequest

public abstract class SpaceScatterGatherOperationRequest<TResult extends SpaceOperationResult>
extends SpaceOperationRequest<TResult>
implements ScatterGatherRemoteOperationRequest<TResult>

Since:

9.0.0

Author:

Niv Ingberg

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected ScatterGatherPartitionInfo	_partitionInfo

Constructor Summary

Constructors

Constructor and Description
SpaceScatterGatherOperationRequest()

Method Summary

Modifier and Type	Method and Description
SpaceScatterGatherOperationRequest<TResult>	createCopy(int targetPartitionId)
void	gather(int[] data, int[] partitionData)
void	gather(OperationResult<Integer>[] data, int[] partitionData)
<T> void	gather(OperationResult<T>[] data, Exception error)
<T> void	gather(T[] data, T partitionData)
<T> void	gather(T[] data, T[] partitionData)
ScatterGatherPartitionInfo	getPartitionInfo()
protected int[]	scatter(int[] data)
protected long[]	scatter(long[] data)
protected <T> T[]	scatter(T[] data, T[] partitionData)

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

afterOperationExecution, beforeOperationExecution, clone, getAsyncFinalResult, getPreciseDistributionGroupingCode, getRemoteOperationResult, getSpaceContext, getTransaction, hasLockedResources, isBlockingOperation, isDedicatedPoolRequired, isDirectExecutionEnabled, processPartitionResult, processUnknownTypeException, readExternal, requiresPartitionedPreciseDistribution, setRemoteOperationExecutionError, setRemoteOperationResult, setSpaceContext, supportsSecurity, toString, toText, writeExternal

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.internal.remoting.routing.partitioned.ScatterGatherRemoteOperationRequest

loadPartitionData, processPartitionResult, scatterIndexesToPartitions

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

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

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

getLRMIMethodTrackingId

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Methods inherited from interface java.io.Externalizable

readExternal, writeExternal

Field Detail

_partitionInfo

protected ScatterGatherPartitionInfo _partitionInfo

Constructor Detail

SpaceScatterGatherOperationRequest

public SpaceScatterGatherOperationRequest()

Method Detail

createCopy

public SpaceScatterGatherOperationRequest<TResult> createCopy(int targetPartitionId)

Specified by:

createCopy in interface RemoteOperationRequest<TResult extends SpaceOperationResult>

Overrides:

createCopy in class SpaceOperationRequest<TResult extends SpaceOperationResult>

getPartitionInfo

public ScatterGatherPartitionInfo getPartitionInfo()

Specified by:

getPartitionInfo in interface ScatterGatherRemoteOperationRequest<TResult extends SpaceOperationResult>

scatter

protected int[] scatter(int[] data)

scatter

protected long[] scatter(long[] data)

scatter

protected <T> T[] scatter(T[] data,
                          T[] partitionData)

gather

public void gather(int[] data,
                   int[] partitionData)

gather

public <T> void gather(T[] data,
                       T[] partitionData)

gather

public void gather(OperationResult<Integer>[] data,
                   int[] partitionData)

gather

public <T> void gather(OperationResult<T>[] data,
                       Exception error)

gather

public <T> void gather(T[] data,
                       T partitionData)