com.gigaspaces.internal.server.space

Class ReadByIdsContext

java.lang.Object

com.gigaspaces.internal.server.space.ReadByIdsContext

All Implemented Interfaces:

Serializable

public class ReadByIdsContext
extends Object
implements Serializable

Created by boris on 12/30/2014. Contains the context for each readByIds (also used in clearByIds - AKA clear(IdsQuery query)). Since 10.1.0

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ReadByIdsContext(ITemplatePacket template, boolean accumulate)

Method Summary

Modifier and Type	Method and Description
boolean	accumulate()
void	addFailure(Object id, Exception e)
void	applyResult(AnswerPacket answerPacket, int resultIndex) Apply the result - store the result (readByIds) or count the cleared objects (clearByIds)
Map<Object,Exception>	getFailures()
IEntryPacket[]	getResults()
int	getSuccessCount()
ITemplatePacket	getTemplate()
void	initResultsEntryPackets() if the operation not requires to accumulate set null, otherwise initialize the results for the readByIds operation

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadByIdsContext

public ReadByIdsContext(ITemplatePacket template,
                        boolean accumulate)

Method Detail

accumulate

public boolean accumulate()

Returns:

true if the context should accumulate results, false otherwise

initResultsEntryPackets

public void initResultsEntryPackets()

if the operation not requires to accumulate set null, otherwise initialize the results for the readByIds operation

applyResult

public void applyResult(AnswerPacket answerPacket,
                        int resultIndex)

Apply the result - store the result (readByIds) or count the cleared objects (clearByIds)

Parameters:

answerPacket - the answer which were returned from the readById request

resultIndex - the index of the result

getSuccessCount

public int getSuccessCount()

getResults

public IEntryPacket[] getResults()

getTemplate

public ITemplatePacket getTemplate()

getFailures

public Map<Object,Exception> getFailures()

addFailure

public void addFailure(Object id,
                       Exception e)