Modifier and Type | Method and Description |
---|---|
void |
IPojoSpace.clear(Object template,
Transaction transaction)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
int |
IPojoSpace.clear(Object template,
Transaction transaction,
int modifiers)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
int |
IPojoSpace.count(Object template,
Transaction transaction)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
int |
IPojoSpace.count(Object template,
Transaction transaction,
int modifiers)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Object |
IPojoSpace.read(Object template,
Transaction transaction,
long timeout)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Object |
IPojoSpace.read(Object template,
Transaction transaction,
long timeout,
int modifiers)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Object |
IPojoSpace.readIfExists(Object template,
Transaction transaction,
long timeout)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Object |
IPojoSpace.readIfExists(Object template,
Transaction transaction,
long timeout,
int modifiers)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Object[] |
IPojoSpace.readMultiple(Object template,
Transaction transaction,
int limit)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Object[] |
IPojoSpace.readMultiple(Object template,
Transaction transaction,
int limit,
int modifiers)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Object |
IPojoSpace.take(Object template,
Transaction transaction,
long timeout)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Object |
IPojoSpace.take(Object template,
Transaction transaction,
long timeout,
int modifiers)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Object |
IPojoSpace.takeIfExists(Object template,
Transaction transaction,
long timeout)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Object[] |
IPojoSpace.takeMultiple(Object template,
Transaction transaction,
int limit)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Object[] |
IPojoSpace.takeMultiple(Object template,
Transaction txn,
int limit,
int modifiers)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Object |
IPojoSpace.update(Object updatedEntry,
Transaction transaction,
long lease,
long timeout)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Object |
IPojoSpace.update(Object updatedEntry,
Transaction transaction,
long lease,
long timeout,
int modifiers)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Object[] |
IPojoSpace.updateMultiple(Object[] entries,
Transaction transaction,
long[] leases)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Object[] |
IPojoSpace.updateMultiple(Object[] objects,
Transaction transaction,
long[] leases,
int modifiers)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Modifier and Type | Method and Description |
---|---|
Object |
AbstractSpaceCacheContainer.readById(ReadTakeProxyActionInfo actionInfo) |
Object |
AbstractSpaceCacheContainer.readById(String className,
Object id,
Object routing,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
QueryResultTypeInternal resultType,
String[] projections) |
Modifier and Type | Method and Description |
---|---|
AsyncFuture<?> |
LocalCacheImplReadTakeAction.asyncRead(LocalCacheContainer spaceProxy,
ReadTakeAsyncProxyActionInfo actionInfo) |
AsyncFuture<?> |
LocalCacheImplReadTakeAction.asyncTake(LocalCacheContainer spaceProxy,
ReadTakeAsyncProxyActionInfo actionInfo) |
int |
LocalCacheImplCountClearAction.execute(LocalCacheContainer spaceProxy,
CountClearProxyActionInfo actionInfo) |
Object |
LocalCacheImplReadTakeAction.read(LocalCacheContainer spaceProxy,
ReadTakeProxyActionInfo actionInfo) |
Object[] |
LocalCacheImplReadTakeByIdsAction.readByIds(LocalCacheContainer spaceProxy,
ReadTakeByIdsProxyActionInfo actionInfo,
boolean returnPackets) |
Object[] |
LocalCacheImplReadTakeMultipleAction.readMultiple(LocalCacheContainer spaceProxy,
ReadTakeMultipleProxyActionInfo actionInfo) |
ReadTakeEntriesUidsResult |
LocalCacheImplReadTakeEntriesUidsAction.readTakeEntriesUids(LocalCacheContainer spaceProxy,
ReadTakeEntriesUidsSpaceOperationRequest request) |
Object |
LocalCacheImplReadTakeAction.take(LocalCacheContainer spaceProxy,
ReadTakeProxyActionInfo actionInfo) |
Object[] |
LocalCacheImplReadTakeByIdsAction.takeByIds(LocalCacheContainer spaceProxy,
ReadTakeByIdsProxyActionInfo actionInfo,
boolean returnPackets) |
Object[] |
LocalCacheImplReadTakeMultipleAction.takeMultiple(LocalCacheContainer spaceProxy,
ReadTakeMultipleProxyActionInfo actionInfo) |
Modifier and Type | Method and Description |
---|---|
int |
LocalViewImplCountClearAction.execute(LocalViewContainer spaceProxy,
CountClearProxyActionInfo actionInfo) |
Object |
LocalViewImplReadTakeAction.read(LocalViewContainer spaceProxy,
ReadTakeProxyActionInfo actionInfo) |
Object[] |
LocalViewImplReadTakeByIdsAction.readByIds(LocalViewContainer spaceProxy,
ReadTakeByIdsProxyActionInfo actionInfo,
boolean returnPackets) |
Object[] |
LocalViewImplReadTakeMultipleAction.readMultiple(LocalViewContainer spaceProxy,
ReadTakeMultipleProxyActionInfo actionInfo) |
ReadTakeEntriesUidsResult |
LocalViewImplReadTakeEntriesUidsAction.readTakeEntriesUids(LocalViewContainer spaceProxy,
ReadTakeEntriesUidsSpaceOperationRequest request) |
Object[] |
LocalViewImplReadTakeByIdsAction.takeByIds(LocalViewContainer spaceProxy,
ReadTakeByIdsProxyActionInfo actionInfo,
boolean returnPackets) |
Object[] |
LocalViewImplReadTakeMultipleAction.takeMultiple(LocalViewContainer spaceProxy,
ReadTakeMultipleProxyActionInfo actionInfo) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractSpaceProxy.clear(Object template,
Transaction txn) |
int |
AbstractSpaceProxy.clear(Object template,
Transaction txn,
int modifiers) |
int |
AbstractSpaceProxy.count(Object template,
Transaction txn) |
int |
AbstractSpaceProxy.count(Object template,
Transaction txn,
int modifiers) |
Entry |
AbstractSpaceProxy.read(Entry template,
Transaction txn,
long timeout) |
Object |
AbstractSpaceProxy.read(Object template,
Transaction txn,
long timeout) |
Object |
AbstractSpaceProxy.read(Object template,
Transaction txn,
long timeout,
int modifiers) |
Object |
ISpaceProxy.read(Object template,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists) |
Object |
AbstractSpaceProxy.read(Object template,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists) |
Object |
ISpaceProxy.readById(ReadTakeProxyActionInfo actionInfo) |
Object |
AbstractSpaceProxy.readById(ReadTakeProxyActionInfo actionInfo) |
Object |
ISpaceProxy.readById(String className,
Object id,
Object routing,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
QueryResultTypeInternal resultType,
String[] projections) |
Object |
AbstractSpaceProxy.readById(String className,
Object id,
Object routing,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
QueryResultTypeInternal resultType,
String[] projections) |
Object[] |
ISpaceProxy.readByIds(ReadTakeByIdsProxyActionInfo actionInfo,
boolean returnPackets) |
Object[] |
AbstractSpaceProxy.readByIds(ReadTakeByIdsProxyActionInfo actionInfo,
boolean returnPackets) |
Object[] |
ISpaceProxy.readByIds(String className,
Object[] ids,
Object[] routings,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPackets,
String[] projections) |
Object[] |
AbstractSpaceProxy.readByIds(String className,
Object[] ids,
Object[] routings,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPackets,
String[] projections) |
Object[] |
ISpaceProxy.readByIds(String className,
Object[] ids,
Object routing,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPackets,
String[] projections) |
Object[] |
AbstractSpaceProxy.readByIds(String className,
Object[] ids,
Object routing,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPackets,
String[] projections) |
Object |
ISpaceProxy.readByUid(String uid,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPacket) |
Object |
AbstractSpaceProxy.readByUid(String uid,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPacket) |
ReadTakeEntriesUidsResult |
ISpaceProxy.readEntriesUids(ITemplatePacket template,
Transaction transaction,
int entriesLimit,
int modifiers)
Read entries UIDs from space.
|
ReadTakeEntriesUidsResult |
AbstractSpaceProxy.readEntriesUids(ITemplatePacket template,
Transaction transaction,
int entriesLimit,
int modifiers) |
Entry |
AbstractSpaceProxy.readIfExists(Entry template,
Transaction txn,
long timeout) |
Object |
AbstractSpaceProxy.readIfExists(Object template,
Transaction txn,
long timeout) |
Object |
AbstractSpaceProxy.readIfExists(Object template,
Transaction txn,
long timeout,
int modifiers) |
Object[] |
AbstractSpaceProxy.readMultiple(Object template,
Transaction txn,
int maxEntries) |
Object[] |
AbstractSpaceProxy.readMultiple(Object template,
Transaction txn,
int maxEntries,
int modifiers) |
Object[] |
ISpaceProxy.readMultiple(Object template,
Transaction transaction,
int limit,
int modifiers,
boolean returnOnlyUids) |
Object[] |
AbstractSpaceProxy.readMultiple(Object template,
Transaction txn,
int maxEntries,
int modifiers,
boolean returnOnlyUids) |
Object[] |
ISpaceProxy.readMultiple(Object template,
Transaction transaction,
long timeout,
int limit,
int minEntriesToWaitFor,
int modifiers,
boolean returnOnlyUids,
boolean ifExist) |
Object[] |
AbstractSpaceProxy.readMultiple(Object template,
Transaction txn,
long timeout,
int maxEntries,
int minEntriesToWaitFor,
int modifiers,
boolean returnOnlyUids,
boolean ifExist) |
Entry |
AbstractSpaceProxy.take(Entry template,
Transaction txn,
long timeout) |
Object |
AbstractSpaceProxy.take(Object template,
Transaction txn,
long timeout) |
Object |
AbstractSpaceProxy.take(Object template,
Transaction txn,
long timeout,
int modifiers) |
Object |
ISpaceProxy.take(Object template,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists) |
Object |
AbstractSpaceProxy.take(Object template,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists) |
Object |
ISpaceProxy.takeById(ReadTakeProxyActionInfo actionInfo) |
Object |
AbstractSpaceProxy.takeById(ReadTakeProxyActionInfo actionInfo) |
Object |
ISpaceProxy.takeById(String className,
Object id,
Object routing,
int version,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
QueryResultTypeInternal resultType,
String[] projections) |
Object |
AbstractSpaceProxy.takeById(String className,
Object id,
Object routing,
int version,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
QueryResultTypeInternal resultType,
String[] projections) |
Object[] |
ISpaceProxy.takeByIds(ReadTakeByIdsProxyActionInfo actionInfo,
boolean returnPackets) |
Object[] |
AbstractSpaceProxy.takeByIds(ReadTakeByIdsProxyActionInfo actionInfo,
boolean returnPackets) |
Object[] |
ISpaceProxy.takeByIds(String className,
Object[] ids,
Object[] routings,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPackets,
String[] projections) |
Object[] |
AbstractSpaceProxy.takeByIds(String className,
Object[] ids,
Object[] routings,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPackets,
String[] projections) |
Object[] |
ISpaceProxy.takeByIds(String className,
Object[] ids,
Object routing,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPackets,
String[] projections) |
Object[] |
AbstractSpaceProxy.takeByIds(String className,
Object[] ids,
Object routing,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPackets,
String[] projections) |
Object |
ISpaceProxy.takeByUid(String uid,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPacket) |
Object |
AbstractSpaceProxy.takeByUid(String uid,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPacket) |
Entry |
AbstractSpaceProxy.takeIfExists(Entry template,
Transaction txn,
long timeout) |
Object |
AbstractSpaceProxy.takeIfExists(Object template,
Transaction txn,
long timeout) |
Object |
AbstractSpaceProxy.takeIfExists(Object template,
Transaction txn,
long timeout,
int modifiers) |
Object[] |
AbstractSpaceProxy.takeMultiple(Object template,
Transaction txn,
int maxEntries) |
Object[] |
AbstractSpaceProxy.takeMultiple(Object template,
Transaction txn,
int maxEntries,
int modifiers) |
Object[] |
ISpaceProxy.takeMultiple(Object template,
Transaction transaction,
int limit,
int modifiers,
boolean returnOnlyUids) |
Object[] |
AbstractSpaceProxy.takeMultiple(Object template,
Transaction txn,
int maxEntries,
int modifiers,
boolean returnOnlyUids) |
Object[] |
ISpaceProxy.takeMultiple(Object template,
Transaction transaction,
long timeout,
int limit,
int minEntriesToWaitFor,
int modifiers,
boolean returnOnlyUids,
boolean ifExist) |
Object[] |
AbstractSpaceProxy.takeMultiple(Object template,
Transaction txn,
long timeout,
int maxEntries,
int minEntriesToWaitFor,
int modifiers,
boolean returnOnlyUids,
boolean ifExist) |
Object |
AbstractSpaceProxy.update(Object updatedEntry,
Transaction transaction,
long lease,
long timeout) |
Object |
AbstractSpaceProxy.update(Object entry,
Transaction txn,
long lease,
long timeout,
int modifiers) |
Object[] |
AbstractSpaceProxy.updateMultiple(Object[] entries,
Transaction txn,
long[] leases) |
Object[] |
AbstractSpaceProxy.updateMultiple(Object[] entries,
Transaction txn,
long[] leases,
int modifiers) |
Modifier and Type | Method and Description |
---|---|
AsyncFuture<?> |
SpaceProxyImplReadTakeAction.asyncRead(SpaceProxyImpl spaceProxy,
ReadTakeAsyncProxyActionInfo actionInfo) |
abstract AsyncFuture<?> |
ReadTakeProxyAction.asyncRead(TSpaceProxy spaceProxy,
ReadTakeAsyncProxyActionInfo actionInfo) |
AsyncFuture<?> |
SpaceProxyImplReadTakeAction.asyncTake(SpaceProxyImpl spaceProxy,
ReadTakeAsyncProxyActionInfo actionInfo) |
abstract AsyncFuture<?> |
ReadTakeProxyAction.asyncTake(TSpaceProxy spaceProxy,
ReadTakeAsyncProxyActionInfo actionInfo) |
int |
AbstractSpaceProxyActionManager.count(Object template,
Transaction txn,
int modifiers) |
int |
SpaceProxyImplCountClearAction.execute(SpaceProxyImpl spaceProxy,
CountClearProxyActionInfo actionInfo) |
abstract int |
CountClearProxyAction.execute(TSpaceProxy spaceProxy,
CountClearProxyActionInfo actionInfo) |
Object |
AbstractSpaceProxyActionManager.read(Object template,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists) |
Object |
AbstractSpaceProxyActionManager.read(ReadTakeProxyActionInfo actionInfo) |
Object |
SpaceProxyImplReadTakeAction.read(SpaceProxyImpl spaceProxy,
ReadTakeProxyActionInfo actionInfo) |
abstract Object |
ReadTakeProxyAction.read(TSpaceProxy spaceProxy,
ReadTakeProxyActionInfo actionInfo) |
Object |
AbstractSpaceProxyActionManager.readById(String className,
Object id,
Object routing,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
QueryResultTypeInternal resultType,
String[] projections) |
Object[] |
AbstractSpaceProxyActionManager.readByIds(ReadTakeByIdsProxyActionInfo actionInfo,
boolean returnPackets) |
Object[] |
SpaceProxyImplReadTakeByIdsAction.readByIds(SpaceProxyImpl spaceProxy,
ReadTakeByIdsProxyActionInfo actionInfo,
boolean returnPackets) |
Object[] |
AbstractSpaceProxyActionManager.readByIds(String className,
Object[] ids,
Object[] routings,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPackets,
String[] projections) |
Object[] |
AbstractSpaceProxyActionManager.readByIds(String className,
Object[] ids,
Object routing,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPackets,
String[] projections) |
abstract Object[] |
ReadTakeByIdsProxyAction.readByIds(TSpaceProxy spaceProxy,
ReadTakeByIdsProxyActionInfo actionInfo,
boolean returnPackets) |
Object |
AbstractSpaceProxyActionManager.readByUid(String uid,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPacket) |
ReadTakeEntriesUidsResult |
AbstractSpaceProxyActionManager.readEntriesUids(ITemplatePacket template,
Transaction transaction,
int entriesLimit,
int modifiers) |
Object[] |
AbstractSpaceProxyActionManager.readMultiple(Object template,
Transaction txn,
long timeout,
int maxEntries,
int minEntriesToWaitFor,
int modifiers,
boolean returnOnlyUids,
boolean ifExist) |
Object[] |
SpaceProxyImplReadTakeMultipleAction.readMultiple(SpaceProxyImpl spaceProxy,
ReadTakeMultipleProxyActionInfo actionInfo) |
abstract Object[] |
ReadTakeMultipleProxyAction.readMultiple(TSpaceProxy spaceProxy,
ReadTakeMultipleProxyActionInfo actionInfo) |
abstract ReadTakeEntriesUidsResult |
ReadTakeEntriesUidsProxyAction.readTakeEntriesUids(TSpaceProxy spaceProxy,
ReadTakeEntriesUidsSpaceOperationRequest request) |
protected void |
ReadTakeMultipleProxyAction.rethrowException(Throwable exception)
Rethrow Exception as typed exception.
|
<T> ISpaceQuery<T> |
SpaceProxyImplSnapshotAction.snapshot(SpaceProxyImpl spaceProxy,
SnapshotProxyActionInfo actionInfo) |
abstract <T> ISpaceQuery<T> |
SnapshotProxyAction.snapshot(TSpaceProxy spaceProxy,
SnapshotProxyActionInfo actionInfo) |
Object |
AbstractSpaceProxyActionManager.take(Object template,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists) |
Object |
AbstractSpaceProxyActionManager.take(ReadTakeProxyActionInfo actionInfo) |
Object |
SpaceProxyImplReadTakeAction.take(SpaceProxyImpl spaceProxy,
ReadTakeProxyActionInfo actionInfo) |
abstract Object |
ReadTakeProxyAction.take(TSpaceProxy spaceProxy,
ReadTakeProxyActionInfo actionInfo) |
Object |
AbstractSpaceProxyActionManager.takeById(String className,
Object id,
Object routing,
int version,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
QueryResultTypeInternal resultType,
String[] projections) |
Object[] |
AbstractSpaceProxyActionManager.takeByIds(ReadTakeByIdsProxyActionInfo actionInfo,
boolean returnPackets) |
Object[] |
SpaceProxyImplReadTakeByIdsAction.takeByIds(SpaceProxyImpl spaceProxy,
ReadTakeByIdsProxyActionInfo actionInfo,
boolean returnPackets) |
Object[] |
AbstractSpaceProxyActionManager.takeByIds(String className,
Object[] ids,
Object[] routings,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPackets,
String[] projections) |
Object[] |
AbstractSpaceProxyActionManager.takeByIds(String className,
Object[] ids,
Object routing,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPackets,
String[] projections) |
abstract Object[] |
ReadTakeByIdsProxyAction.takeByIds(TSpaceProxy spaceProxy,
ReadTakeByIdsProxyActionInfo actionInfo,
boolean returnPackets) |
Object |
AbstractSpaceProxyActionManager.takeByUid(String uid,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPacket) |
Object[] |
AbstractSpaceProxyActionManager.takeMultiple(Object template,
Transaction txn,
long timeout,
int maxEntries,
int minEntriesToWaitFor,
int modifiers,
boolean returnOnlyUids,
boolean ifExist) |
Object[] |
SpaceProxyImplReadTakeMultipleAction.takeMultiple(SpaceProxyImpl spaceProxy,
ReadTakeMultipleProxyActionInfo actionInfo) |
abstract Object[] |
ReadTakeMultipleProxyAction.takeMultiple(TSpaceProxy spaceProxy,
ReadTakeMultipleProxyActionInfo actionInfo) |
Modifier and Type | Method and Description |
---|---|
Object |
SpaceProxyTypeManager.getObjectFromIGSEntry(IGSEntry entry) |
Object |
ISpaceProxyTypeManager.getObjectFromIGSEntry(IGSEntry entry) |
Modifier and Type | Method and Description |
---|---|
IEntryPacket |
ReadTakeEntrySpaceOperationRequest.getFinalResult() |
ReadTakeEntriesByIdsSpaceOperationResult |
ReadTakeEntriesByIdsSpaceOperationRequest.getFinalResult() |
int |
CountClearEntriesSpaceOperationRequest.getFinalResult() |
IEntryPacket[] |
ReadTakeEntriesSpaceOperationRequest.getFinalResult() |
ReadTakeEntriesUidsResult |
ReadTakeEntriesUidsSpaceOperationRequest.getFinalResult() |
void |
ReadTakeEntriesSpaceOperationResult.processExecutionException() |
void |
CountClearEntriesSpaceOperationResult.processExecutionException() |
void |
ReadTakeEntriesByIdsSpaceOperationResult.processExecutionException() |
void |
ReadTakeEntriesUidsSpaceOperationResult.processExecutionException() |
Modifier and Type | Method and Description |
---|---|
protected ExtendedAnswerHolder |
PrimaryBackupSpaceReplicationEvictionProtectionEntryEventHandler.executeUpdateOperation(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
IEntryPacket previousEntry,
boolean partialUpdate,
boolean overrideVersion,
long lease,
boolean twoPhaseCommit,
int updateModifiers) |
protected ExtendedAnswerHolder |
AbstractSpaceReplicationEntryEventHandler.executeUpdateOperation(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
IEntryPacket previousEntry,
boolean partialUpdate,
boolean overrideVersion,
long lease,
boolean twoPhaseCommit,
int updateModifiers) |
protected void |
BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.removeEntryFromSpace(IReplicationInContext context,
Transaction txn,
ITemplatePacket template,
boolean twoPhaseCommit) |
protected void |
PrimaryBackupSpaceReplicationEntryEventHandler.removeEntryFromSpace(IReplicationInContext context,
Transaction txn,
ITemplatePacket template,
boolean twoPhaseCommit) |
protected void |
AbstractSpaceReplicationEntryEventHandler.removeEntryFromSpace(IReplicationInContext context,
Transaction txn,
ITemplatePacket template,
boolean twoPhaseCommit) |
protected void |
BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.updateEntryInSpace(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
IEntryPacket previousEntry,
boolean partialUpdate,
boolean overrideVersion,
long lease,
boolean twoPhaseCommit) |
protected void |
PrimaryBackupSpaceReplicationEntryEventHandler.updateEntryInSpace(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
IEntryPacket previousEntry,
boolean partialUpdate,
boolean overrideVersion,
long lease,
boolean twoPhaseCommit) |
protected void |
AbstractSpaceReplicationEntryEventHandler.updateEntryInSpace(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
IEntryPacket previousEntry,
boolean partialUpdate,
boolean overrideVersion,
long lease,
boolean twoPhaseCommit) |
protected ExtendedAnswerHolder |
PrimaryBackupSpaceReplicationEntryEventHandler.updateOrWrite(IReplicationInContext context,
Transaction transaction,
IEntryPacket entryPacket,
long lease,
int updateModifiers) |
protected abstract ExtendedAnswerHolder |
AbstractSpaceReplicationEntryEventHandler.updateOrWrite(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
long lease,
int modifiers) |
protected ExtendedAnswerHolder |
ActiveActiveSpaceReplicationEntryEventHandler.updateOrWrite(IReplicationInContext context,
Transaction transaction,
IEntryPacket entryPacket,
long lease,
int updateModifiers) |
Modifier and Type | Method and Description |
---|---|
Object |
ReplicationFilterUidDataWrapper.getObject(IJSpace space) |
Object |
ReplicationFilterEntryDataWrapper.getObject(IJSpace space) |
Modifier and Type | Method and Description |
---|---|
void |
LRMISpaceImpl.snapshot(ITemplatePacket e) |
Modifier and Type | Method and Description |
---|---|
Object |
SpaceImpl.asyncRead(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
IJSpaceProxyListener listener,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers,
IFuture result) |
ExtendedAnswerHolder |
SpaceEngine.change(ITemplatePacket template,
Transaction txn,
long lease,
long timeout,
SpaceContext sc,
boolean fromReplication,
boolean origin,
Collection<SpaceEntryMutator> mutators,
int operationModifiers,
boolean returnOnlyUid)
perform an update in place using mutators
|
Pair<Integer,SingleExplainPlan> |
SpaceImpl.clear(ITemplatePacket template,
Transaction txn,
int modifiers,
SpaceContext sc) |
Pair<Integer,SingleExplainPlan> |
SpaceEngine.clear(ITemplatePacket template,
Transaction txn,
SpaceContext sc,
int operationModifiers) |
Pair<Integer,SingleExplainPlan> |
SpaceImpl.count(ITemplatePacket template,
Transaction txn,
SpaceContext sc,
int modifiers) |
Pair<Integer,SingleExplainPlan> |
SpaceEngine.count(ITemplatePacket template,
Transaction txn,
SpaceContext sc,
int operationModifiers) |
ServerIteratorAnswerHolder |
SpaceImpl.getNextBatchFromServerIterator(ITemplatePacket template,
SpaceContext sc,
int modifiers,
ServerIteratorRequestInfo serverIteratorRequestInfo) |
AnswerHolder |
SpaceEngine.newUpdateMultiple(IEntryPacket[] entries,
Transaction txn,
long[] leases,
SpaceContext sc,
long timeout,
int operationModifiers)
perform update of multiple entries.
|
GSEventRegistration |
SpaceEngine.notify(ITemplatePacket template,
long lease,
boolean fromReplication,
String templateUid,
SpaceContext sc,
NotifyInfo info) |
GSEventRegistration |
SpaceImpl.notify(ITemplatePacket template,
Transaction txn,
long lease,
SpaceContext sc,
NotifyInfo info) |
AnswerPacket |
SpaceImpl.read(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
IJSpaceProxyListener listener,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers) |
AnswerHolder |
SpaceEngine.read(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
SpaceContext sc,
boolean returnOnlyUid,
boolean fromReplication,
boolean origin,
int operationModifiers) |
IEntryPacket[] |
SpaceImpl.readByIds(ITemplatePacket template,
Transaction txn,
boolean take,
SpaceContext spaceContext,
int modifiers) |
IEntryPacket[] |
SpaceImpl.readMultiple(ITemplatePacket template,
Transaction txn,
boolean take,
int maxEntries,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers) |
AnswerHolder |
SpaceImpl.readMultiple(ITemplatePacket template,
Transaction txn,
boolean take,
int maxEntries,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers,
int minEntries,
long timeout,
boolean isIfExist) |
AnswerHolder |
SpaceEngine.readMultiple(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
SpaceContext sc,
boolean returnOnlyUid,
int operationModifiers,
BatchQueryOperationContext batchOperationContext,
List<SpaceEntriesAggregator> aggregators,
ServerIteratorRequestInfo serverIteratorRequestInfo) |
AnswerHolder |
SpaceImpl.readNew(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
IJSpaceProxyListener listener,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers) |
void |
SpaceEngine.registerLocalView(ITemplatePacket[] queryPackets,
Collection<SpaceQueryDetails> queryDescriptions,
RouterStubHolder viewStub,
int batchSize,
long batchTimeout,
SpaceContext spaceContext) |
void |
SpaceImpl.snapshot(ITemplatePacket template) |
void |
SpaceEngine.snapshot(ITemplatePacket entryPacket)
Return a snapshot of the given entry.
|
void |
IRemoteSpace.snapshot(ITemplatePacket e) |
ExtendedAnswerHolder |
SpaceEngine.update(IEntryPacket updated_entry,
Transaction txn,
long lease,
long timeout,
SpaceContext sc,
boolean fromReplication,
boolean origin,
boolean newRouter,
int modifiers)
perform an update operation- make it atomic NOTE- returnonlyUID is ignored
|
ExtendedAnswerHolder |
SpaceEngine.update(IEntryPacket updated_entry,
Transaction txn,
long lease,
long timeout,
SpaceContext sc,
boolean fromReplication,
boolean origin,
boolean newRouter,
int modifiers,
MultipleIdsContext multipleIdsContext) |
AnswerPacket |
SpaceImpl.update(IEntryPacket entry,
Transaction txn,
long lease,
long timeout,
SpaceContext sc,
int modifiers,
boolean newRouter) |
Object[] |
SpaceEngine.updateMultiple(IEntryPacket[] entries,
Transaction txn,
long[] leases,
SpaceContext sc,
int operationModifiers,
boolean newRouter)
perform update of multiple entries.
|
ExtendedAnswerHolder |
SpaceEngine.updateOrWrite(UpdateOrWriteContext ctx,
boolean newRouter) |
ExtendedAnswerHolder |
SpaceEngine.updateOrWrite(UpdateOrWriteContext ctx,
boolean fromReplication,
boolean origin,
boolean newRouter) |
WriteEntryResult |
SpaceEngine.write(IEntryPacket entryPacket,
Transaction txn,
long lease,
int modifiers,
boolean fromReplication,
boolean origin,
SpaceContext sc)
Creates an IEntryHolder object from the specified entry packet and inserts it into all
relevant engine tables.
|
WriteEntryResult |
SpaceImpl.write(IEntryPacket entry,
Transaction txn,
long lease,
int modifiers,
boolean fromReplication,
SpaceContext sc) |
Modifier and Type | Method and Description |
---|---|
IServerTypeDesc |
SpaceTypeManager.loadServerTypeDesc(ITransportPacket packet) |
Modifier and Type | Class and Description |
---|---|
class |
DetailedUnusableEntryException
A DetailedUnusableEntryException is thrown when class version compatibility error, the space
server contains an older version of class.
|
class |
FifoOperationException
Parent exception class of all Fifo Exceptions.
|
class |
InvalidFifoClassException
Deprecated.
This exception is no longer thrown.
|
class |
InvalidFifoTemplateException
This exception is thrown if read or take operations executed in FIFO mode, but the template class
FIFO mode already been set to non FIFO.
|
Modifier and Type | Method and Description |
---|---|
Entry |
EntryImpl.getEntry(IJSpace space) |
Object |
IGSEntry.getObject(IJSpace space)
Converts to object.
|
Object |
AbstractEntryType.getObject(IJSpace space)
Converts to object.
|
Modifier and Type | Class and Description |
---|---|
class |
EntryNotInSpaceException
This exception is thrown when update operation is rejected.
|
class |
EntryVersionConflictException
This exception is thrown when update/take operation is rejected as a result of optimistic locking
version conflict.
|
Modifier and Type | Method and Description |
---|---|
Entry |
ExternalEntry.getEntry(IJSpace space)
Deprecated.
|
Object |
EntryArrivedRemoteEvent.getObject()
Returns the entry by specification of user.
|
Object |
ExternalEntry.getObject(IJSpace space)
Deprecated.
Converts to object.
|
Constructor and Description |
---|
GSIterator(IJSpace spaceProxy,
Collection<?> templates)
Deprecated.
Equivalent to calling
GSIterator(IJSpace, Collection, com.gigaspaces.client.iterator.GSIteratorConfig) . |
GSIterator(IJSpace spaceProxy,
Collection<?> templates,
GSIteratorConfig config)
Deprecated.
Constructs an iterator over a space using a collection of entity instances to be
incrementally returned.
|
GSIterator(IJSpace spaceProxy,
Collection<?> templates,
int bufferSize,
boolean withHistory,
long leaseDuration)
Deprecated.
Use
GSIterator(IJSpace, Collection, GSIteratorConfig) instead. |
Modifier and Type | Method and Description |
---|---|
IEntryPacket |
QueryManager.readTake(ReadTakeProxyActionInfo actionInfo) |
IEntryPacket |
IQueryManager.readTake(ReadTakeProxyActionInfo actionInfo) |
Modifier and Type | Method and Description |
---|---|
Entry |
SpaceUpdateFilterEntryImpl.getEntry(IJSpace space) |
Entry |
ExecutionFilterEntry.getEntry(IJSpace space)
Deprecated.
|
Object |
ExecutionFilterEntry.getObject(IJSpace space) |
Modifier and Type | Method and Description |
---|---|
WriteEntryResult |
Processor.handleDirectWriteSA(Context context,
IEntryHolder entry,
IServerTypeDesc typeDesc,
boolean fromReplication,
boolean origin,
boolean reInsertedEntry,
boolean supplied_uid,
boolean lockXtnsIfNeeded,
int modifiers)
Handles Direct write SA.
|
Modifier and Type | Method and Description |
---|---|
ArrayList<IEntryPacket> |
QueryTemplatePacket.take(IJSpace space,
Object routing,
AbstractProjectionTemplate projectionTemplate,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
int maxResults,
int minEntriesToWaitFor,
QueryResultTypeInternal resultType) |
Modifier and Type | Method and Description |
---|---|
int |
IQueryExecutor.clear(QueryTemplatePacket template,
ISpaceProxy space,
Transaction txn,
int modifier)
Execute clear
|
int |
AbstractQueryExecutor.clear(QueryTemplatePacket template,
ISpaceProxy space,
Transaction txn,
int modifiers) |
Modifier and Type | Method and Description |
---|---|
void |
JMXSpace.clear(String className)
Removes the entries that match the specified template from this space.
|
int |
JMXSpace.count(String className)
Returns the number of entries.
|
Entry |
TemplateImpl.getEntry(IJSpace space)
Deprecated.
|
Object |
TemplateImpl.getObject(IJSpace space) |
Modifier and Type | Method and Description |
---|---|
Entry |
CacheEntry.getEntry(IJSpace space) |
Modifier and Type | Method and Description |
---|---|
IEntryPacket |
EntryAdapter.toEntry(Object object)
Converts given object to IGSEntry
|
IEntryPacket |
EntryAdapter.toEntry(Object key,
Object value)
Convert key value to entry
|
IEntryPacket |
EntryPacketDataConverter.toInternal(Object obj) |
I |
IDataConverter.toInternal(Object obj)
Converts to internal representation
|
Modifier and Type | Method and Description |
---|---|
Entry |
JavaSpace.read(Entry tmpl,
Transaction txn,
long timeout)
Read any matching entry from the space, blocking until one exists.
|
Entry |
JavaSpace.readIfExists(Entry tmpl,
Transaction txn,
long timeout)
Read any matching entry from the space, returning
null if there is currently is
none. |
Entry |
JavaSpace.take(Entry tmpl,
Transaction txn,
long timeout)
Take a matching entry from the space, waiting until one exists.
|
Entry |
JavaSpace.takeIfExists(Entry tmpl,
Transaction txn,
long timeout)
Take a matching entry from the space, returning
null if there is currently is
none. |
Constructor and Description |
---|
UnusableEntryException(String message,
UnusableEntryException cause) |
UnusableEntryException(UnusableEntryException cause) |
Copyright © GigaSpaces.