Class RegisterLocalViewSpaceOperationRequest

java.lang.Object

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

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

com.gigaspaces.internal.client.spaceproxy.operations.RegisterLocalViewSpaceOperationRequest

All Implemented Interfaces:

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

public class RegisterLocalViewSpaceOperationRequest
extends SpaceScatterGatherOperationRequest<RegisterLocalViewSpaceOperationResult>

Since:

9.5.0

Author:

Niv Ingberg

See Also:

• Serialized Form

Field Summary

Fields inherited from class SpaceScatterGatherOperationRequest

_partitionInfo

Constructor Summary

Constructors

Constructor	Description
RegisterLocalViewSpaceOperationRequest()	Required for Externalizable
RegisterLocalViewSpaceOperationRequest(List<ITemplatePacket>[] allQueryPackets, List<SpaceQueryDetails>[] allQueryDescriptions, RouterStubHolder viewStub, int batchSize, long batchTimeout)

Method Summary

Modifier and Type	Method	Description
RegisterLocalViewSpaceOperationResult	createRemoteOperationResult()
int	getBatchSize()
long	getBatchTimeout()
PartitionedExecutionExceptionsCollection	getErrors()
String	getLRMIMethodTrackingId()
int	getOperationCode()
PartitionedClusterExecutionType	getPartitionedClusterExecutionType()
Object	getPartitionedClusterRoutingValue(PartitionedClusterRemoteOperationRouter router)
Collection<SpaceQueryDetails>	getQueryDescriptions()
Collection<ITemplatePacket>	getQueryPackets()
RouterStubHolder	getViewStub()
void	loadPartitionData(ScatterGatherRemoteOperationRequest<RegisterLocalViewSpaceOperationResult> mainRequest)
boolean	processPartitionResult(ScatterGatherRemoteOperationRequest<RegisterLocalViewSpaceOperationResult> partitionRequest, List<ScatterGatherRemoteOperationRequest<RegisterLocalViewSpaceOperationResult>> previousRequests)
void	readExternal(ObjectInput in)
void	scatterIndexesToPartitions(ScatterGatherOperationFutureListener<RegisterLocalViewSpaceOperationResult> scatterGatherCoordinator)
void	writeExternal(ObjectOutput out)

Methods inherited from class SpaceScatterGatherOperationRequest

createCopy, gather, gather, gather, gather, gather, getPartitionInfo, scatter, scatter, scatter

Methods inherited from class SpaceOperationRequest

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

Methods inherited from class Object

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

Methods inherited from interface RemoteOperationRequest

getAsyncFinalResult, getPreciseDistributionGroupingCode, getRemoteOperationResult, getSpaceContext, isBlockingOperation, isDedicatedPoolRequired, isDirectExecutionEnabled, processPartitionResult, processUnknownTypeException, requiresPartitionedPreciseDistribution, setRemoteOperationExecutionError, setRemoteOperationResult

Methods inherited from interface SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Details

RegisterLocalViewSpaceOperationRequest

public RegisterLocalViewSpaceOperationRequest()

Required for Externalizable

RegisterLocalViewSpaceOperationRequest

public RegisterLocalViewSpaceOperationRequest(List<ITemplatePacket>[] allQueryPackets,
 List<SpaceQueryDetails>[] allQueryDescriptions,
 RouterStubHolder viewStub,
 int batchSize,
 long batchTimeout)

Method Details

getOperationCode

public int getOperationCode()

createRemoteOperationResult

public RegisterLocalViewSpaceOperationResult createRemoteOperationResult()

getPartitionedClusterExecutionType

public PartitionedClusterExecutionType getPartitionedClusterExecutionType()

getPartitionedClusterRoutingValue

public Object getPartitionedClusterRoutingValue(PartitionedClusterRemoteOperationRouter router)

getLRMIMethodTrackingId

public String getLRMIMethodTrackingId()

getQueryPackets

public Collection<ITemplatePacket> getQueryPackets()

getQueryDescriptions

public Collection<SpaceQueryDetails> getQueryDescriptions()

getViewStub

public RouterStubHolder getViewStub()

getBatchSize

public int getBatchSize()

getBatchTimeout

public long getBatchTimeout()

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class SpaceOperationRequest<RegisterLocalViewSpaceOperationResult>

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class SpaceOperationRequest<RegisterLocalViewSpaceOperationResult>

Throws:

IOException

ClassNotFoundException

scatterIndexesToPartitions

public void scatterIndexesToPartitions(ScatterGatherOperationFutureListener<RegisterLocalViewSpaceOperationResult> scatterGatherCoordinator)

loadPartitionData

public void loadPartitionData(ScatterGatherRemoteOperationRequest<RegisterLocalViewSpaceOperationResult> mainRequest)

processPartitionResult

public boolean processPartitionResult(ScatterGatherRemoteOperationRequest<RegisterLocalViewSpaceOperationResult> partitionRequest,
 List<ScatterGatherRemoteOperationRequest<RegisterLocalViewSpaceOperationResult>> previousRequests)

getErrors

public PartitionedExecutionExceptionsCollection getErrors()