Package com.gigaspaces.internal.server.space

Class AggregateOperationContext

java.lang.Object

com.gigaspaces.internal.server.space.BatchQueryOperationContext

com.gigaspaces.internal.server.space.AggregateOperationContext

public class AggregateOperationContext
extends BatchQueryOperationContext

Created by niv on 6/17/14.

Field Summary

Fields inherited from class com.gigaspaces.internal.server.space.BatchQueryOperationContext

_processedUids

Constructor Summary

Constructors

Constructor	Description
AggregateOperationContext(ITemplatePacket template, int maxEntries, int minEntries, boolean skipProcessedUidsStore)

Method Summary

Modifier and Type	Method	Description
void	addToProcessedUidsIfNeeded(String uid)
void	createProcessedUidsIfNeeded()
boolean	hasAnyEntries()
boolean	isInProcessedUids(String uid)
protected boolean	keepResultsInBatchContext()
boolean	needProcessEntriesForReturnedResult()
boolean	needToProcessExecption()
void	onException(Throwable t)	Handles an exception that was thrown while executing the batch operation

Methods inherited from class com.gigaspaces.internal.server.space.BatchQueryOperationContext

addResult, createResultList, getExceptions, getMaxEntries, getMinEntries, getNumResults, getResults, isClear, processReturnedValueForBatchOperation, reachedMaxEntries, reachedMinEntries, setExceptions, setResults

Methods inherited from class java.lang.Object

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

Constructor Details

AggregateOperationContext

public AggregateOperationContext(ITemplatePacket template,
 int maxEntries,
 int minEntries,
 boolean skipProcessedUidsStore)

Method Details

onException

public void onException(Throwable t)

Description copied from class: BatchQueryOperationContext

Handles an exception that was thrown while executing the batch operation

Specified by:

onException in class BatchQueryOperationContext

needToProcessExecption

public boolean needToProcessExecption()

Overrides:

needToProcessExecption in class BatchQueryOperationContext

needProcessEntriesForReturnedResult

public boolean needProcessEntriesForReturnedResult()

Overrides:

needProcessEntriesForReturnedResult in class BatchQueryOperationContext

createProcessedUidsIfNeeded

public void createProcessedUidsIfNeeded()

Overrides:

createProcessedUidsIfNeeded in class BatchQueryOperationContext

isInProcessedUids

public boolean isInProcessedUids(String uid)

Overrides:

isInProcessedUids in class BatchQueryOperationContext

addToProcessedUidsIfNeeded

public void addToProcessedUidsIfNeeded(String uid)

Overrides:

addToProcessedUidsIfNeeded in class BatchQueryOperationContext

keepResultsInBatchContext

protected boolean keepResultsInBatchContext()

Overrides:

keepResultsInBatchContext in class BatchQueryOperationContext

hasAnyEntries

public boolean hasAnyEntries()

Overrides:

hasAnyEntries in class BatchQueryOperationContext