com.gigaspaces.internal.client.spaceproxy.actioninfo

Class ReadTakeMultipleProxyActionInfo

java.lang.Object

com.gigaspaces.internal.client.spaceproxy.actioninfo.CommonProxyActionInfo

com.gigaspaces.internal.client.spaceproxy.actioninfo.QueryProxyActionInfo

com.gigaspaces.internal.client.spaceproxy.actioninfo.ReadTakeMultipleProxyActionInfo

All Implemented Interfaces:

Cloneable

public class ReadTakeMultipleProxyActionInfo
extends QueryProxyActionInfo

Field Summary

Fields

Modifier and Type	Field and Description
boolean	ifExist
boolean	isTake
int	maxResults
int	minEntriesToWaitFor
boolean	returnOnlyUids
long	timeout

Fields inherited from class com.gigaspaces.internal.client.spaceproxy.actioninfo.QueryProxyActionInfo

_devLogger, _query, _queryObjectType, isSqlQuery, queryPacket

Fields inherited from class com.gigaspaces.internal.client.spaceproxy.actioninfo.CommonProxyActionInfo

modifiers, txn

Constructor Summary

Constructors

Constructor and Description
ReadTakeMultipleProxyActionInfo(ISpaceProxy spaceProxy, Object template, Transaction txn, long timeout, int maxEntries, int minEntriesToWaitFor, int modifiers, boolean returnOnlyUids, boolean isTake, boolean ifExist)

Method Summary

Modifier and Type	Method and Description
QueryMultiplePartialFailureException	convertExceptionResults(ISpaceProxy spaceProxy, QueryMultiplePartialFailureException e, AbstractProjectionTemplate projectionTemplate)
Object[]	convertQueryResults(ISpaceProxy spaceProxy, IEntryPacket[] results, AbstractProjectionTemplate projectionTemplate)
int	getSyncReplicationLevel()
List<ReplicationLevel>	getSyncReplicationLevels()
boolean	requireTransactionForMVCC()
void	setSyncReplicationLevel(int syncReplicationLevel)
void	setSyncReplicationLevels(List<ReplicationLevel> syncReplicationLevels)

Methods inherited from class com.gigaspaces.internal.client.spaceproxy.actioninfo.QueryProxyActionInfo

clearProjectionTemplate, clone, getQuery, setFifoIfNeeded, verifyLogScannedEntriesCountParams

Methods inherited from class com.gigaspaces.internal.client.spaceproxy.actioninfo.CommonProxyActionInfo

initOperationId, toEntryPacket, validateReadModifiers

Methods inherited from class java.lang.Object

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

Field Detail

maxResults

public final int maxResults

returnOnlyUids

public final boolean returnOnlyUids

isTake

public final boolean isTake

timeout

public final long timeout

minEntriesToWaitFor

public final int minEntriesToWaitFor

ifExist

public boolean ifExist

Constructor Detail

ReadTakeMultipleProxyActionInfo

public ReadTakeMultipleProxyActionInfo(ISpaceProxy spaceProxy,
                                       Object template,
                                       Transaction txn,
                                       long timeout,
                                       int maxEntries,
                                       int minEntriesToWaitFor,
                                       int modifiers,
                                       boolean returnOnlyUids,
                                       boolean isTake,
                                       boolean ifExist)

Method Detail

convertQueryResults

public Object[] convertQueryResults(ISpaceProxy spaceProxy,
                                    IEntryPacket[] results,
                                    AbstractProjectionTemplate projectionTemplate)

convertExceptionResults

public QueryMultiplePartialFailureException convertExceptionResults(ISpaceProxy spaceProxy,
                                                                    QueryMultiplePartialFailureException e,
                                                                    AbstractProjectionTemplate projectionTemplate)

getSyncReplicationLevel

public int getSyncReplicationLevel()

setSyncReplicationLevel

public void setSyncReplicationLevel(int syncReplicationLevel)

setSyncReplicationLevels

public void setSyncReplicationLevels(List<ReplicationLevel> syncReplicationLevels)

getSyncReplicationLevels

public List<ReplicationLevel> getSyncReplicationLevels()

requireTransactionForMVCC

public boolean requireTransactionForMVCC()

Overrides:

requireTransactionForMVCC in class CommonProxyActionInfo