Package 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	Description
protected ScatterGatherPartitionInfo	_partitionInfo

Constructor Summary

Constructors

Constructor	Description
SpaceScatterGatherOperationRequest()

Method Summary

Modifier and Type	Method	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 java.io.Externalizable

readExternal, writeExternal

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

getLRMIMethodTrackingId

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.internal.remoting.routing.partitioned.ScatterGatherRemoteOperationRequest

loadPartitionData, processPartitionResult, scatterIndexesToPartitions

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Field Details

_partitionInfo

protected ScatterGatherPartitionInfo _partitionInfo

Constructor Details

SpaceScatterGatherOperationRequest

public SpaceScatterGatherOperationRequest()

Method Details

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)