Package com.gigaspaces.internal.client.spaceproxy.operations

Class AggregateEntriesSpaceOperationRequest

java.lang.Object

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

com.gigaspaces.internal.client.spaceproxy.operations.AggregateEntriesSpaceOperationRequest

All Implemented Interfaces:

RemoteOperationRequest<AggregateEntriesSpaceOperationResult>, Textualizable, LRMIMethodTrackingIdProvider, SmartExternalizable, Externalizable, Serializable, Cloneable

public class AggregateEntriesSpaceOperationRequest
extends SpaceOperationRequest<AggregateEntriesSpaceOperationResult>

Since:

10.0

Author:

Niv Ingberg

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
AggregateEntriesSpaceOperationRequest()	Required for Externalizable
AggregateEntriesSpaceOperationRequest(ITemplatePacket queryPacket, Transaction txn, int modifiers, List<SpaceEntriesAggregator> aggregators)

Method Summary

Modifier and Type	Method	Description
void	afterOperationExecution(int partitionId)
RemoteOperationRequest<AggregateEntriesSpaceOperationResult>	createCopy(int targetPartitionId)
AggregateEntriesSpaceOperationResult	createRemoteOperationResult()
List<SpaceEntriesAggregator>	getAggregators()
ExplainPlan	getExplainPlan()
AggregationResult	getFinalResult(IJSpace spaceProxy, ITemplatePacket queryPacket, boolean returnEntryPacket)
String	getLRMIMethodTrackingId()
int	getOperationCode()
PartitionedClusterExecutionType	getPartitionedClusterExecutionType()
Object	getPartitionedClusterRoutingValue(PartitionedClusterRemoteOperationRouter router)
ITemplatePacket	getQueryPacket()
int	getReadModifiers()
boolean	processPartitionResult(AggregateEntriesSpaceOperationResult remoteOperationResult, List<AggregateEntriesSpaceOperationResult> previousResults, int numOfPartitions)
void	readExternal(ObjectInput in)
void	setQueryPacket(ITemplatePacket queryPacket)
void	writeExternal(ObjectOutput out)

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

beforeOperationExecution, clone, getAsyncFinalResult, getPreciseDistributionGroupingCode, getRemoteOperationResult, getSpaceContext, getTransaction, hasLockedResources, isBlockingOperation, isDedicatedPoolRequired, isDirectExecutionEnabled, 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.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Details

AggregateEntriesSpaceOperationRequest

public AggregateEntriesSpaceOperationRequest()

Required for Externalizable

AggregateEntriesSpaceOperationRequest

public AggregateEntriesSpaceOperationRequest(ITemplatePacket queryPacket,
 Transaction txn,
 int modifiers,
 List<SpaceEntriesAggregator> aggregators)

Method Details

getOperationCode

public int getOperationCode()

createRemoteOperationResult

public AggregateEntriesSpaceOperationResult createRemoteOperationResult()

createCopy

public RemoteOperationRequest<AggregateEntriesSpaceOperationResult> createCopy(int targetPartitionId)

Specified by:

createCopy in interface RemoteOperationRequest<AggregateEntriesSpaceOperationResult>

Overrides:

createCopy in class SpaceOperationRequest<AggregateEntriesSpaceOperationResult>

getPartitionedClusterExecutionType

public PartitionedClusterExecutionType getPartitionedClusterExecutionType()

getPartitionedClusterRoutingValue

public Object getPartitionedClusterRoutingValue(PartitionedClusterRemoteOperationRouter router)

processPartitionResult

public boolean processPartitionResult(AggregateEntriesSpaceOperationResult remoteOperationResult,
 List<AggregateEntriesSpaceOperationResult> previousResults,
 int numOfPartitions)

Specified by:

processPartitionResult in interface RemoteOperationRequest<AggregateEntriesSpaceOperationResult>

Overrides:

processPartitionResult in class SpaceOperationRequest<AggregateEntriesSpaceOperationResult>

afterOperationExecution

public void afterOperationExecution(int partitionId)

Overrides:

afterOperationExecution in class SpaceOperationRequest<AggregateEntriesSpaceOperationResult>

getFinalResult

public AggregationResult getFinalResult(IJSpace spaceProxy,
 ITemplatePacket queryPacket,
 boolean returnEntryPacket)
                                 throws TransactionException,
InterruptedException,
RemoteException

Throws:

TransactionException

InterruptedException

RemoteException

getLRMIMethodTrackingId

public String getLRMIMethodTrackingId()

getQueryPacket

public ITemplatePacket getQueryPacket()

setQueryPacket

public void setQueryPacket(ITemplatePacket queryPacket)

getAggregators

public List<SpaceEntriesAggregator> getAggregators()

getReadModifiers

public int getReadModifiers()

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class SpaceOperationRequest<AggregateEntriesSpaceOperationResult>

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class SpaceOperationRequest<AggregateEntriesSpaceOperationResult>

Throws:

IOException

ClassNotFoundException

getExplainPlan

public ExplainPlan getExplainPlan()