com.gigaspaces.internal.server.space

Class BatchQueryOperationContext

java.lang.Object

com.gigaspaces.internal.server.space.BatchQueryOperationContext

Direct Known Subclasses:

AggregateOperationContext, ChangeMultipleContext, ClearContext, ReadMultipleContext, TakeMultipleContext

public abstract class BatchQueryOperationContext
extends Object

Context for batch query operations. Accumulates batch results and exceptions.

Since:

7.1

Author:

anna

Field Summary

Fields

Modifier and Type	Field and Description
protected HashSet<String>	_processedUids

Constructor Summary

Constructors

Constructor and Description
BatchQueryOperationContext(ITemplatePacket template, int maxEntries, int minEntries)

Method Summary

Modifier and Type	Method and Description
void	addResult(IEntryPacket result)
void	addToProcessedUidsIfNeeded(String uid)
protected void	createProcessedUidsIfNeeded()
protected List<IEntryPacket>	createResultList(ITemplatePacket template, int maxEntries) Create a list that will accumulate the batch operation results.
List<Throwable>	getExceptions()
int	getMaxEntries()
int	getMinEntries()
int	getNumResults()
List<IEntryPacket>	getResults()
boolean	hasAnyEntries()
boolean	isClear()
boolean	isInProcessedUids(String uid)
protected boolean	keepResultsInBatchContext()
boolean	needProcessEntriesForReturnedResult()
boolean	needToProcessExecption()
abstract void	onException(Throwable t) Handles an exception that was thrown while executing the batch operation
IEntryPacket[]	processReturnedValueForBatchOperation(ITemplateHolder template)
boolean	reachedMaxEntries()
boolean	reachedMinEntries()
void	setExceptions(List<Throwable> exceptions)
protected void	setResults(List<IEntryPacket> _results)

Methods inherited from class java.lang.Object

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

Field Detail

_processedUids

protected HashSet<String> _processedUids

Constructor Detail

BatchQueryOperationContext

public BatchQueryOperationContext(ITemplatePacket template,
                                  int maxEntries,
                                  int minEntries)

Method Detail

createResultList

protected List<IEntryPacket> createResultList(ITemplatePacket template,
                                              int maxEntries)

Create a list that will accumulate the batch operation results.

addResult

public void addResult(IEntryPacket result)

keepResultsInBatchContext

protected boolean keepResultsInBatchContext()

setResults

protected void setResults(List<IEntryPacket> _results)

getResults

public List<IEntryPacket> getResults()

getNumResults

public int getNumResults()

getExceptions

public List<Throwable> getExceptions()

setExceptions

public void setExceptions(List<Throwable> exceptions)

reachedMinEntries

public boolean reachedMinEntries()

reachedMaxEntries

public boolean reachedMaxEntries()

onException

public abstract void onException(Throwable t)

Handles an exception that was thrown while executing the batch operation

needToProcessExecption

public boolean needToProcessExecption()

needProcessEntriesForReturnedResult

public boolean needProcessEntriesForReturnedResult()

processReturnedValueForBatchOperation

public IEntryPacket[] processReturnedValueForBatchOperation(ITemplateHolder template)

getMaxEntries

public int getMaxEntries()

getMinEntries

public int getMinEntries()

hasAnyEntries

public boolean hasAnyEntries()

createProcessedUidsIfNeeded

protected void createProcessedUidsIfNeeded()

isInProcessedUids

public boolean isInProcessedUids(String uid)

addToProcessedUidsIfNeeded

public void addToProcessedUidsIfNeeded(String uid)

isClear

public boolean isClear()