com.gigaspaces.internal.client.spaceproxy.operations

Class RegisterLocalViewSpaceOperationRequest

java.lang.Object

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

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

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

All Implemented Interfaces:

RemoteOperationRequest<RegisterLocalViewSpaceOperationResult>, ScatterGatherRemoteOperationRequest<RegisterLocalViewSpaceOperationResult>, Textualizable, LRMIMethodTrackingIdProvider, 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 com.gigaspaces.internal.client.spaceproxy.operations.SpaceScatterGatherOperationRequest

_partitionInfo

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 com.gigaspaces.internal.client.spaceproxy.operations.SpaceScatterGatherOperationRequest

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

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

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

Methods inherited from class java.lang.Object

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

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

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

Constructor Detail

RegisterLocalViewSpaceOperationRequest

public RegisterLocalViewSpaceOperationRequest()

Required for Externalizable

RegisterLocalViewSpaceOperationRequest

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

Method Detail

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