Package 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	Description
boolean	ifExist
final boolean	isTake
final int	maxResults
final int	minEntriesToWaitFor
final boolean	returnOnlyUids
final 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	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	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 Details

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 Details

ReadTakeMultipleProxyActionInfo

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

Method Details

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