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. |
LeaseContext |
IPojoSpace.write(Object object,
Transaction transaction,
long lease)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
LeaseContext |
IPojoSpace.write(Object object,
Transaction transaction,
long lease,
long timeout,
int modifiers)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
LeaseContext[] |
IPojoSpace.writeMultiple(Object[] objects,
Transaction transaction,
long lease)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
LeaseContext[] |
IPojoSpace.writeMultiple(Object[] objects,
Transaction transaction,
long[] leases,
int modifiers)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
LeaseContext[] |
IPojoSpace.writeMultiple(Object[] objects,
Transaction transaction,
long lease,
int modifiers)
Deprecated.
Since 8.0 - Use
GigaSpace instead. |
Constructor and Description |
---|
SpaceEntryPacketIterator(ISpaceProxy spaceProxy,
Object query,
Transaction txn,
int batchSize,
int modifiers) |
SpaceIterator(ISpaceProxy spaceProxy,
Object query,
Transaction txn,
int batchSize,
ReadModifiers modifiers) |
Modifier and Type | Class and Description |
---|---|
class |
GSServerTransaction
Title: GSServerTransaction Description: Extends the ServerTransaction to hold Object id
should only be used as a key.
|
Modifier and Type | Method and Description |
---|---|
T |
SpaceTask.execute(IJSpace space,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
void |
LocalCache.removeFromCache(String uid,
Transaction txn,
boolean disableInsertions) |
void |
LocalCache.updateCache(IEntryPacket updatedPacket,
Object objectToUpdateWith,
Transaction txn,
long lease,
int updateModifiers,
long updateTime) |
void |
LocalCache.updateCache(IEntryPacket updatedPacket,
Transaction transaction,
long lease,
int updateModifiers,
long updateTime) |
Constructor and Description |
---|
GCEntry(long ttl,
Transaction xtn) |
GCEntry(Transaction xtn) |
Modifier and Type | Method and Description |
---|---|
AsyncFuture |
LocalCacheImplAdminAction.execute(LocalCacheContainer spaceProxy,
SpaceTask task,
Object routing,
Transaction txn,
AsyncFutureListener listener) |
Modifier and Type | Method and Description |
---|---|
AsyncFuture |
LocalViewImplAdminAction.execute(LocalViewContainer spaceProxy,
SpaceTask task,
Object routing,
Transaction txn,
AsyncFutureListener listener) |
Modifier and Type | Method and Description |
---|---|
void |
LocalViewReplicationEntryEventHandler.changeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String typeName,
String uid,
Object id,
int routingHash,
int version,
int previousVersion,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntry) |
void |
LocalViewReplicationEntryEventHandler.removeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
IEntryPacket entry) |
void |
LocalViewReplicationEntryEventHandler.removeEntryByUid(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String uid,
boolean isTransient,
OperationID operationID) |
void |
LocalViewReplicationEntryEventHandler.updateEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
IEntryPacket entry,
IEntryPacket previousPacket,
boolean partialUpdate,
boolean overrideVersion) |
void |
LocalViewReplicationEntryEventHandler.writeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
IEntryPacket entry) |
Modifier and Type | Method and Description |
---|---|
Transaction |
SpaceProxyImpl.beforeSpaceAction() |
Transaction |
SpaceProxyImpl.beforeSpaceAction(Transaction txn) |
Modifier and Type | Method and Description |
---|---|
AggregationResult |
AbstractSpaceProxy.aggregate(Object template,
AggregationSet aggregationSet,
Transaction txn,
int readModifiers) |
AggregationResult |
ISpaceProxy.aggregate(Object template,
AggregationSet aggregationSet,
Transaction txn,
int readModifiers) |
<T> Future<ChangeResult<T>> |
AbstractSpaceProxy.asyncChange(Object template,
ChangeSet changeSet,
Transaction txn,
long timeout,
ChangeModifiers modifiers,
AsyncFutureListener<ChangeResult<T>> listener) |
<T> Future<ChangeResult<T>> |
ISpaceProxy.asyncChange(Object template,
ChangeSet changeSet,
Transaction txn,
long timeout,
ChangeModifiers modifiers,
AsyncFutureListener<ChangeResult<T>> listener) |
AsyncFuture<?> |
AbstractSpaceProxy.asyncRead(Object template,
Transaction txn,
long timeout,
int modifiers,
AsyncFutureListener listener) |
AsyncFuture |
ISpaceProxy.asyncRead(Object template,
Transaction transaction,
long timeout,
int modifiers,
AsyncFutureListener listener)
Internal methods only.
|
AsyncFuture<?> |
AbstractSpaceProxy.asyncTake(Object template,
Transaction txn,
long timeout,
int modifiers,
AsyncFutureListener listener) |
AsyncFuture |
ISpaceProxy.asyncTake(Object template,
Transaction transaction,
long timeout,
int modifiers,
AsyncFutureListener listener)
Internal methods only.
|
Transaction |
SpaceProxyImpl.beforeSpaceAction(Transaction txn) |
<T> ChangeResult<T> |
AbstractSpaceProxy.change(Object template,
ChangeSet changeSet,
Transaction txn,
long timeout,
ChangeModifiers modifiers) |
<T> ChangeResult<T> |
ISpaceProxy.change(Object template,
ChangeSet changeSet,
Transaction txn,
long timeout,
ChangeModifiers modifiers)
Change entry in space
|
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) |
AsyncFuture |
AbstractSpaceProxy.execute(SpaceTask task,
Object routing,
Transaction tx,
AsyncFutureListener listener) |
AsyncFuture |
ISpaceProxy.execute(SpaceTask task,
Object routing,
Transaction tx,
AsyncFutureListener listener)
Executes a task on a single space.
|
EventRegistration |
AbstractSpaceProxy.notify(Entry template,
Transaction txn,
RemoteEventListener listener,
long lease,
MarshalledObject handback) |
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 |
AbstractSpaceProxy.read(Object template,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists) |
Object |
ISpaceProxy.read(Object template,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists) |
Object |
AbstractSpaceProxy.readById(String className,
Object id,
Object routing,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
QueryResultTypeInternal resultType,
String[] projections) |
Object |
ISpaceProxy.readById(String className,
Object id,
Object routing,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
QueryResultTypeInternal resultType,
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[] routings,
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.readByIds(String className,
Object[] ids,
Object routing,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPackets,
String[] projections) |
Object |
AbstractSpaceProxy.readByUid(String uid,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPacket) |
Object |
ISpaceProxy.readByUid(String uid,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPacket) |
ReadTakeEntriesUidsResult |
AbstractSpaceProxy.readEntriesUids(ITemplatePacket template,
Transaction transaction,
int entriesLimit,
int modifiers) |
ReadTakeEntriesUidsResult |
ISpaceProxy.readEntriesUids(ITemplatePacket template,
Transaction transaction,
int entriesLimit,
int modifiers)
Read entries UIDs from space.
|
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[] |
AbstractSpaceProxy.readMultiple(Object template,
Transaction txn,
int maxEntries,
int modifiers,
boolean returnOnlyUids) |
Object[] |
ISpaceProxy.readMultiple(Object template,
Transaction transaction,
int limit,
int modifiers,
boolean returnOnlyUids) |
Object[] |
AbstractSpaceProxy.readMultiple(Object template,
Transaction txn,
long timeout,
int maxEntries,
int minEntriesToWaitFor,
int modifiers,
boolean returnOnlyUids,
boolean ifExist) |
Object[] |
ISpaceProxy.readMultiple(Object template,
Transaction transaction,
long timeout,
int limit,
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 |
AbstractSpaceProxy.take(Object template,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists) |
Object |
ISpaceProxy.take(Object template,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists) |
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.takeById(String className,
Object id,
Object routing,
int version,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
QueryResultTypeInternal resultType,
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[] routings,
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.takeByIds(String className,
Object[] ids,
Object routing,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPackets,
String[] projections) |
Object |
AbstractSpaceProxy.takeByUid(String uid,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPacket) |
Object |
ISpaceProxy.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[] |
AbstractSpaceProxy.takeMultiple(Object template,
Transaction txn,
int maxEntries,
int modifiers,
boolean returnOnlyUids) |
Object[] |
ISpaceProxy.takeMultiple(Object template,
Transaction transaction,
int limit,
int modifiers,
boolean returnOnlyUids) |
Object[] |
AbstractSpaceProxy.takeMultiple(Object template,
Transaction txn,
long timeout,
int maxEntries,
int minEntriesToWaitFor,
int modifiers,
boolean returnOnlyUids,
boolean ifExist) |
Object[] |
ISpaceProxy.takeMultiple(Object template,
Transaction transaction,
long timeout,
int limit,
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) |
Lease |
AbstractSpaceProxy.write(Entry entry,
Transaction txn,
long lease) |
LeaseContext<?> |
AbstractSpaceProxy.write(Object entry,
Transaction txn,
long lease) |
LeaseContext<?> |
AbstractSpaceProxy.write(Object entry,
Transaction txn,
long lease,
long timeout,
int modifiers) |
LeaseContext<?>[] |
AbstractSpaceProxy.writeMultiple(Object[] objects,
Transaction txn,
long lease) |
LeaseContext<?>[] |
AbstractSpaceProxy.writeMultiple(Object[] objects,
Transaction txn,
long[] leases,
int modifiers) |
LeaseContext<?>[] |
AbstractSpaceProxy.writeMultiple(Object[] objects,
Transaction txn,
long lease,
int modifiers) |
LeaseContext<?>[] |
AbstractSpaceProxy.writeMultiple(Object[] objects,
Transaction txn,
long lease,
long[] leases,
int modifiers) |
LeaseContext<?>[] |
AbstractSpaceProxy.writeMultiple(Object[] objects,
Transaction txn,
long lease,
long[] leases,
long timeout,
int modifiers) |
LeaseContext[] |
ISpaceProxy.writeMultiple(Object[] objects,
Transaction txn,
long lease,
long[] leases,
long timeout,
int modifiers) |
Modifier and Type | Field and Description |
---|---|
Transaction |
CommonProxyActionInfo.txn |
Constructor and Description |
---|
AggregateProxyActionInfo(ISpaceProxy spaceProxy,
Object query,
AggregationSet aggregationSet,
Transaction txn,
int modifiers) |
ChangeProxyActionInfo(ISpaceProxy spaceProxy,
Object template,
ChangeSet changeSet,
Transaction txn,
long timeout,
ChangeModifiers modifiers) |
CommonProxyActionInfo(Transaction txn,
int modifiers) |
CountClearProxyActionInfo(ISpaceProxy spaceProxy,
Object query,
Transaction txn,
int modifiers,
boolean isTake) |
CountClearProxyActionInfo(ISpaceProxy spaceProxy,
Object query,
Transaction txn,
int modifiers,
boolean isTake,
boolean isClear) |
QueryProxyActionInfo(ISpaceProxy spaceProxy,
Object query,
Transaction txn,
int modifiers,
boolean requiresOperationId) |
QueryProxyActionInfo(ISpaceProxy spaceProxy,
Object query,
Transaction txn,
int modifiers,
boolean requiresOperationId,
boolean supportIdsQuery) |
QueryProxyActionInfo(ISpaceProxy spaceProxy,
Transaction txn,
int modifiers) |
ReadTakeAsyncProxyActionInfo(ISpaceProxy spaceProxy,
Object template,
Transaction txn,
long timeout,
int modifiers,
boolean isTake,
AsyncFutureListener<?> listener) |
ReadTakeByIdsProxyActionInfo(ISpaceProxy spaceProxy,
String className,
Object[] ids,
Object routing,
Object[] routings,
Transaction txn,
boolean isTake,
int modifiers,
QueryResultTypeInternal queryResultType,
String[] projections,
AbstractProjectionTemplate projectionTemplate) |
ReadTakeMultipleProxyActionInfo(ISpaceProxy spaceProxy,
Object template,
Transaction txn,
long timeout,
int maxEntries,
int minEntriesToWaitFor,
int modifiers,
boolean returnOnlyUids,
boolean isTake,
boolean ifExist) |
ReadTakeProxyActionInfo(ISpaceProxy spaceProxy,
Object template,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
boolean isTake) |
ReadTakeProxyActionInfo(ISpaceProxy spaceProxy,
String className,
Object id,
Object routing,
int version,
Transaction txn,
long timeout,
int modifiers,
QueryResultTypeInternal resultType,
boolean ifExists,
boolean isTake,
String[] projections,
AbstractProjectionTemplate projectionTemplate) |
ReadTakeProxyActionInfo(ISpaceProxy spaceProxy,
String uid,
Transaction txn,
int modifiers,
QueryResultTypeInternal resultType,
boolean returnPacket,
boolean ifExists,
boolean isTake) |
WriteMultipleProxyActionInfo(ISpaceProxy spaceProxy,
Object[] entries,
Transaction txn,
long lease,
long[] leases,
long timeout,
int modifiers) |
WriteProxyActionInfo(ISpaceProxy spaceProxy,
Object entry,
Transaction txn,
long lease,
long timeout,
int modifiers) |
Modifier and Type | Method and Description |
---|---|
AggregationResult |
AbstractSpaceProxyActionManager.aggregate(Object query,
AggregationSet aggregationSet,
Transaction txn,
int modifiers) |
<T> Future<ChangeResult<T>> |
AbstractSpaceProxyActionManager.asyncChange(Object template,
ChangeSet changeSet,
Transaction txn,
long timeout,
ChangeModifiers modifiers,
AsyncFutureListener<ChangeResult<T>> listener) |
AsyncFuture<?> |
AbstractSpaceProxyActionManager.asyncRead(Object template,
Transaction txn,
long timeout,
int modifiers,
AsyncFutureListener<?> listener) |
AsyncFuture<?> |
AbstractSpaceProxyActionManager.asyncTake(Object template,
Transaction txn,
long timeout,
int modifiers,
AsyncFutureListener<?> listener) |
<T> ChangeResult<T> |
AbstractSpaceProxyActionManager.change(Object template,
ChangeSet changeSet,
Transaction txn,
long timeout,
ChangeModifiers modifiers) |
int |
AbstractSpaceProxyActionManager.clear(Object template,
Transaction txn,
int modifiers) |
int |
AbstractSpaceProxyActionManager.count(Object template,
Transaction txn,
int modifiers) |
AsyncFuture |
SpaceProxyImplAdminAction.execute(SpaceProxyImpl spaceProxy,
SpaceTask task,
Object routing,
Transaction txn,
AsyncFutureListener listener) |
abstract AsyncFuture |
AdminProxyAction.execute(TSpaceProxy spaceProxy,
SpaceTask task,
Object routing,
Transaction txn,
AsyncFutureListener listener) |
AsyncFuture |
AbstractSpaceProxyActionManager.executeTask(SpaceTask task,
Object routing,
Transaction tx,
AsyncFutureListener listener) |
Object |
AbstractSpaceProxyActionManager.read(Object template,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists) |
Object |
AbstractSpaceProxyActionManager.readById(String className,
Object id,
Object routing,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
QueryResultTypeInternal resultType,
String[] projections) |
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) |
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 |
AbstractSpaceProxyActionManager.take(Object template,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists) |
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(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) |
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) |
LeaseContext<?> |
AbstractSpaceProxyActionManager.write(Object entry,
Transaction txn,
long lease,
long timeout,
int modifiers) |
LeaseContext<?>[] |
AbstractSpaceProxyActionManager.writeMultiple(Object[] objects,
Transaction txn,
long lease,
long[] leases,
long timeout,
int modifiers) |
Modifier and Type | Method and Description |
---|---|
T |
SystemTask.execute(IJSpace spaceProxy,
Transaction tx) |
AddTypeIndexesResult |
AddTypeIndexesTask.execute(IJSpace space,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
Transaction |
ReadTakeEntrySpaceOperationRequest.getTransaction() |
Transaction |
SpaceOperationRequest.getTransaction() |
Transaction |
ReadTakeEntriesSpaceOperationRequest.getTransaction() |
Transaction |
ReadTakeEntriesUidsSpaceOperationRequest.getTransaction() |
Transaction |
ChangeEntriesSpaceOperationRequest.getTransaction() |
Transaction |
ExecuteTaskSpaceOperationRequest.getTransaction() |
Transaction |
ReadTakeEntriesByIdsSpaceOperationRequest.getTransaction() |
Transaction |
CountClearEntriesSpaceOperationRequest.getTransaction() |
Transaction |
WriteEntrySpaceOperationRequest.getTransaction() |
Transaction |
WriteEntriesSpaceOperationRequest.getTransaction() |
Constructor and Description |
---|
AggregateEntriesSpaceOperationRequest(ITemplatePacket queryPacket,
Transaction txn,
int modifiers,
List<SpaceEntriesAggregator> aggregators) |
ChangeEntriesSpaceOperationRequest(ITemplatePacket templatePacket,
Transaction txn,
long timeout,
long lease,
int modifiers,
Collection<SpaceEntryMutator> mutators,
Object query) |
CountClearEntriesSpaceOperationRequest(ITemplatePacket templatePacket,
Transaction txn,
boolean isClear,
int modifiers) |
ExecuteTaskSpaceOperationRequest(SpaceTask<?> task,
Transaction txn,
Object routingValue) |
ReadTakeEntriesByIdsSpaceOperationRequest(AbstractIdsQueryPacket queryPacket,
boolean isTake,
int modifiers,
Transaction transaction) |
ReadTakeEntriesSpaceOperationRequest(ITemplatePacket templatePacket,
Transaction transaction,
boolean isTake,
int modifiers,
int maxResults,
int minResultsToWaitFor,
long timeout,
boolean ifExist,
Object query) |
ReadTakeEntriesUidsSpaceOperationRequest(ITemplatePacket template,
Transaction transaction,
int entriesLimit,
int modifiers) |
ReadTakeEntrySpaceOperationRequest(ITemplatePacket templatePacket,
Transaction txn,
boolean isTake,
boolean ifExists,
long timeout,
int modifiers,
boolean returnOnlyUid,
ISpaceProxyTypeManager typeManager,
boolean returnPacket,
Object query) |
ReadTakeEntrySpaceOperationRequest(ITemplatePacket templatePacket,
Transaction txn,
boolean isTake,
boolean ifExists,
long timeout,
int modifiers,
boolean returnOnlyUid,
Object query) |
WriteEntriesSpaceOperationRequest(ISpaceProxyTypeManager typeManager,
Object[] entries,
IEntryPacket[] entriesPackets,
Transaction txn,
long lease,
long[] leases,
long timeout,
int modifiers) |
WriteEntrySpaceOperationRequest(IEntryPacket entryPacket,
Transaction txn,
long lease,
long timeout,
int modifiers,
boolean isUpdate) |
Modifier and Type | Method and Description |
---|---|
Transaction |
SpaceProxyTransactionManager.beforeSpaceAction(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
Transaction |
SpaceProxyTransactionManager.beforeSpaceAction(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
abstract void |
AbstractReplicationEntryEventHandler.changeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String typeName,
String uid,
Object id,
int routingHash,
int version,
int previousVersion,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntryData) |
abstract void |
AbstractReplicationEntryEventHandler.removeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
IEntryPacket entry) |
abstract void |
AbstractReplicationEntryEventHandler.removeEntryByUid(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String uid,
boolean isTransient,
OperationID operationID) |
abstract void |
AbstractReplicationEntryEventHandler.updateEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
IEntryPacket entry,
IEntryPacket previousPacket,
boolean partialUpdate,
boolean overrideVersion) |
abstract void |
AbstractReplicationEntryEventHandler.writeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
IEntryPacket entry) |
Modifier and Type | Method and Description |
---|---|
abstract boolean |
AbstractLocalClusterOperationData.execute(Transaction transaction)
Executes the operation against the provided
ISpaceProxy with the provided Transaction instance. |
boolean |
LocalClusterRemoveByUIDOperationData.execute(Transaction transaction) |
boolean |
LocalClusterChangeOperationData.execute(Transaction transaction) |
boolean |
AbstractLocalClusterWriteOperationData.execute(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractSpaceReplicationEntryEventHandler.changeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String typeName,
String uid,
Object id,
int routingHash,
int version,
int previousVersion,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntry) |
void |
SpaceReplicationTransactionEventHandler.changeEntry(IReplicationInContext context,
Transaction transaction,
boolean twoPhaseCommit,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
long timeToLive,
int routingHash,
Collection<SpaceEntryMutator> spaceEntryMutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntryData) |
protected void |
BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.changeEntryInSpace(IReplicationInContext context,
Transaction txn,
String uid,
int version,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntry,
long timeToLive,
boolean twoPhaseCommit) |
protected void |
PrimaryBackupSpaceReplicationEntryEventHandler.changeEntryInSpace(IReplicationInContext context,
Transaction txn,
String uid,
int version,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntry,
long timeToLive,
boolean twoPhaseCommit) |
protected void |
AbstractSpaceReplicationEntryEventHandler.changeEntryInSpace(IReplicationInContext context,
Transaction txn,
String uid,
int version,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntry,
long timeToLive,
boolean twoPhaseCommit) |
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) |
void |
SpaceReplicationTransactionEventHandler.removeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
IEntryPacket entry) |
void |
AbstractSpaceReplicationEntryEventHandler.removeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
IEntryPacket entry) |
void |
AbstractSpaceReplicationEntryEventHandler.removeEntryByUid(IReplicationInContext context,
Transaction transaction,
boolean twoPhaseCommit,
String uid,
boolean isTransient,
OperationID operationID) |
void |
SpaceReplicationTransactionEventHandler.removeEntryByUID(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String uid,
boolean isTransient,
OperationID operationID) |
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 boolean |
ActiveActiveSpaceReplicationEntryEventHandler.shouldChangeEntryInSpace(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String typeName,
String uid,
boolean isTransient,
int version) |
protected boolean |
PrimaryBackupSpaceReplicationEntryEventHandler.shouldChangeEntryInSpace(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String typeName,
String uid,
boolean isTransient,
int version) |
protected abstract boolean |
AbstractSpaceReplicationEntryEventHandler.shouldChangeEntryInSpace(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String typeName,
String uid,
boolean isTransient,
int version) |
protected boolean |
ActiveActiveSpaceReplicationEntryEventHandler.shouldUpdateEntryInSpace(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
IEntryPacket entry) |
protected boolean |
PrimaryBackupSpaceReplicationEntryEventHandler.shouldUpdateEntryInSpace(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
IEntryPacket entry) |
protected abstract boolean |
AbstractSpaceReplicationEntryEventHandler.shouldUpdateEntryInSpace(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
IEntryPacket entry) |
void |
AbstractSpaceReplicationEntryEventHandler.updateEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
IEntryPacket entry,
IEntryPacket previousEntry,
boolean partialUpdate,
boolean overrideVersion) |
void |
SpaceReplicationTransactionEventHandler.updateEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
IEntryPacket entry,
IEntryPacket previousEntryPacket,
boolean partialUpdate,
boolean overrideVersion,
short flags) |
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 |
ActiveActiveSpaceReplicationEntryEventHandler.updateOrWrite(IReplicationInContext context,
Transaction transaction,
IEntryPacket entryPacket,
long lease,
int updateModifiers) |
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) |
void |
SpaceReplicationTransactionEventHandler.writeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
IEntryPacket entry) |
void |
AbstractSpaceReplicationEntryEventHandler.writeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
IEntryPacket entry) |
protected void |
BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.writeEntryIntoSpace(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
long lease,
boolean twoPhaseCommit) |
protected void |
PrimaryBackupSpaceReplicationEntryEventHandler.writeEntryIntoSpace(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
long lease,
boolean twoPhaseCommit) |
protected void |
AbstractSpaceReplicationEntryEventHandler.writeEntryIntoSpace(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
long lease,
boolean twoPhaseCommit) |
Modifier and Type | Method and Description |
---|---|
void |
ITransactionalExecutionCallback.changeEntry(IReplicationInContext context,
Transaction transaction,
boolean twoPhaseCommit,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
long timeToLive,
int routingHash,
Collection<SpaceEntryMutator> spaceEntryMutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntryData) |
void |
IReplicationTransactionalPacketEntryData.executeTransactional(IReplicationInContext context,
ITransactionalExecutionCallback transactionExecutionCallback,
Transaction transaction,
boolean twoPhaseCommit) |
void |
ITransactionalExecutionCallback.removeEntry(IReplicationInContext context,
Transaction transaction,
boolean twoPhaseCommit,
IEntryPacket entryPacket) |
void |
ITransactionalExecutionCallback.removeEntryByUID(IReplicationInContext context,
Transaction transaction,
boolean twoPhaseCommit,
String uid,
boolean isTransient,
OperationID operationID) |
void |
ITransactionalExecutionCallback.updateEntry(IReplicationInContext context,
Transaction transaction,
boolean twoPhaseCommit,
IEntryPacket entryPacket,
IEntryPacket previousEntryPacket,
boolean partialUpdate,
boolean overrideVersion,
short flags) |
void |
ITransactionalExecutionCallback.writeEntry(IReplicationInContext context,
Transaction transaction,
boolean twoPhaseCommit,
IEntryPacket entryPacket) |
Modifier and Type | Method and Description |
---|---|
void |
UpdateReplicationPacketData.executeTransactional(IReplicationInContext context,
ITransactionalExecutionCallback transactionExecutionCallback,
Transaction transaction,
boolean twoPhaseCommit) |
void |
WriteReplicationPacketData.executeTransactional(IReplicationInContext context,
ITransactionalExecutionCallback transactionExecutionCallback,
Transaction transaction,
boolean twoPhaseCommit) |
void |
ChangeReplicationPacketData.executeTransactional(IReplicationInContext context,
ITransactionalExecutionCallback transactionExecutionCallback,
Transaction transaction,
boolean twoPhaseCommit) |
void |
RemoveReplicationPacketData.executeTransactional(IReplicationInContext context,
ITransactionalExecutionCallback transactionExecutionCallback,
Transaction transaction,
boolean twoPhaseCommit) |
void |
RemoveByUIDReplicationPacketData.executeTransactional(IReplicationInContext context,
ITransactionalExecutionCallback transactionExecutionCallback,
Transaction transaction,
boolean twoPhaseCommit) |
void |
PartialUpdateReplicationPacketData.executeTransactional(IReplicationInContext context,
ITransactionalExecutionCallback transactionExecutionCallback,
Transaction transaction,
boolean twoPhaseCommit) |
Modifier and Type | Method and Description |
---|---|
List<UnderTxnLockedObject> |
LRMISpaceImpl.getLockedObjects(Transaction txn) |
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> |
SpaceEngine.count(ITemplatePacket template,
Transaction txn,
SpaceContext sc,
int operationModifiers) |
Pair<Integer,SingleExplainPlan> |
SpaceImpl.count(ITemplatePacket template,
Transaction txn,
SpaceContext sc,
int modifiers) |
Object |
SpaceImpl.executeTask(SpaceTask task,
Transaction tx,
SpaceContext sc,
boolean newRouter) |
List<UnderTxnLockedObject> |
SpaceEngine.getLockedObjects(Transaction txn)
getLockedObjects returns Info about all the locked Object by the given Transaction.
|
List<UnderTxnLockedObject> |
SpaceImpl.getLockedObjects(Transaction txn)
getLockedObjects is called by the GUI.
|
AnswerHolder |
SpaceEngine.newAdaptUpdateMultiple(IEntryPacket[] entries,
Transaction txn,
long lease,
long[] leases,
SpaceContext sc,
long timeout,
int modifiers) |
AnswerHolder |
SpaceEngine.newUpdateMultiple(IEntryPacket[] entries,
Transaction txn,
long[] leases,
SpaceContext sc,
long timeout,
int operationModifiers)
perform update of multiple entries.
|
GSEventRegistration |
SpaceImpl.notify(ITemplatePacket template,
Transaction txn,
long lease,
SpaceContext sc,
NotifyInfo info) |
WriteEntriesResult |
SpaceEngine.oldAdaptUpdateMultiple(IEntryPacket[] entries,
Transaction txn,
long lease,
long[] leases,
SpaceContext sc,
int modifiers,
boolean newRouter) |
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) |
AnswerHolder |
SpaceImpl.readNew(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
IJSpaceProxyListener listener,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers) |
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.
|
WriteEntriesResult |
SpaceEngine.write(IEntryPacket[] entryPackets,
Transaction txn,
long lease,
long[] leases,
int modifiers,
SpaceContext sc,
long timeout,
boolean newRouter)
Creates IEntryHolder objects from the specified entry packets and inserts them into all
relevant engine tables.
|
WriteEntriesResult |
SpaceImpl.write(IEntryPacket[] entries,
Transaction txn,
long lease,
long[] leases,
SpaceContext sc,
long timeout,
int modifiers,
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) |
LeaseContext<?>[] |
SpaceImpl.writeOld(IEntryPacket[] entries,
Transaction txn,
long lease,
long[] leases,
SpaceContext sc,
int modifiers) |
Modifier and Type | Method and Description |
---|---|
Transaction |
SpaceTransactionProvider.getCurrentTransaction()
Returns the currently running transaction (usually managed externally/declarative).
|
Modifier and Type | Field and Description |
---|---|
Transaction |
UpdateOrWriteContext.tx |
Constructor and Description |
---|
UpdateOrWriteContext(IEntryPacket packet,
long lease,
long timeout,
Transaction tx,
SpaceContext sc,
int operationModifiers,
boolean fromUpdateMultiple,
boolean updateOperation,
boolean fromWriteMultiple) |
UpdateOrWriteContext(IEntryPacket packet,
long lease,
long timeout,
Transaction tx,
SpaceContext sc,
int operationModifiers,
boolean fromUpdateMultiple,
boolean updateOperation,
boolean fromWriteMultiple,
ITemplateHolder concentratingTemplate,
int ordinalInMultipleIdsContext) |
Modifier and Type | Method and Description |
---|---|
List<UnderTxnLockedObject> |
JSpaceAdminImpl.getLockedObjects(Transaction txn) |
List<UnderTxnLockedObject> |
IInternalRemoteJSpaceAdmin.getLockedObjects(Transaction txn)
getLockedObjects is called by the GUI.
|
List<UnderTxnLockedObject> |
JSpaceAdminProxy.getLockedObjects(Transaction txn) |
Modifier and Type | Method and Description |
---|---|
Transaction |
TransactionInfo.getTrasaction()
Returns the transaction that own the info.
|
Modifier and Type | Method and Description |
---|---|
void |
ActionListener.action(Transaction txn)
Called by ActionMaker on event
|
void |
XAResourceImpl.action(Transaction txn) |
Constructor and Description |
---|
TransactionInfo(int type,
int status,
Transaction trasaction,
long lease,
long startTime,
int numberOfLockedObjects)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected Object |
MapCache.internalGet(Object key,
Transaction txn,
long waitForResponse,
int readModifiers) |
protected Object |
MapCache.internalPut(Object key,
Object value,
Transaction txn,
long timeToLive,
long timeout) |
protected Object |
MapCache.internalRemove(Object key,
Transaction txn,
long waitForResponse) |
Modifier and Type | Method and Description |
---|---|
ITemplatePacket |
IQueryManager.getSQLTemplate(SQLQueryTemplatePacket template,
Transaction txn) |
ITemplatePacket |
QueryManager.getSQLTemplate(SQLQueryTemplatePacket template,
Transaction txn) |
Modifier and Type | Method and Description |
---|---|
Transaction |
QuerySession.getTransaction() |
Modifier and Type | Method and Description |
---|---|
static IQueryResultSet<IEntryPacket> |
AggregationsUtil.aggregate(QueryTemplatePacket template,
AggregationSet aggregationSet,
IJSpace space,
Transaction txn,
int modifiers)
Execute aggregation query
|
ArrayList<IEntryPacket> |
DeleteQuery.executeExclusiveReadLock(QueryTemplatePacket template,
IJSpace space,
Transaction txn,
int max,
int modifiers) |
ResponsePacket |
CreateTableQuery.executeOnSpace(ISpaceProxy space,
Transaction txn)
The main logic method, execute the query on the space by calling snapshot
|
ResponsePacket |
SelectQuery.executeOnSpace(ISpaceProxy space,
Transaction txn)
Execute the query
|
ResponsePacket |
DropTableQuery.executeOnSpace(ISpaceProxy space,
Transaction txn) |
ResponsePacket |
DeleteQuery.executeOnSpace(ISpaceProxy space,
Transaction txn) |
ResponsePacket |
AlterTableQuery.executeOnSpace(ISpaceProxy space,
Transaction txn) |
ResponsePacket |
UpdateQuery.executeOnSpace(ISpaceProxy space,
Transaction txn) |
ResponsePacket |
InsertQuery.executeOnSpace(ISpaceProxy space,
Transaction txn) |
ResponsePacket |
Query.executeOnSpace(ISpaceProxy space,
Transaction txn)
Will execute this query on the space and return a ResponsePacket
|
ResponsePacket |
ProcedureQuery.executeOnSpace(ISpaceProxy space,
Transaction txn) |
ResponsePacket |
CommitQuery.executeOnSpace(ISpaceProxy space,
Transaction txn) |
BatchResponsePacket |
SelectQuery.executePreparedValuesBatch(ISpaceProxy space,
Transaction transaction,
GPreparedStatement.PreparedValuesCollection preparedValuesCollection) |
BatchResponsePacket |
UpdateQuery.executePreparedValuesBatch(ISpaceProxy space,
Transaction transaction,
GPreparedStatement.PreparedValuesCollection preparedValuesCollection) |
BatchResponsePacket |
InsertQuery.executePreparedValuesBatch(ISpaceProxy space,
Transaction transaction,
GPreparedStatement.PreparedValuesCollection preparedValuesCollection) |
BatchResponsePacket |
AbstractDMLQuery.executePreparedValuesBatch(ISpaceProxy space,
Transaction transaction,
GPreparedStatement.PreparedValuesCollection preparedValuesCollection)
Executes a query with batched prepared values.
|
protected void |
AbstractDMLQuery.executeSubQueries(ISpaceProxy space,
Transaction txn) |
void |
AbstractDMLQuery.prepare(ISpaceProxy space,
Transaction txn)
Set the prepared values on the expression tree
|
void |
QuerySession.setTransaction(Transaction txn) |
void |
QueryProcessor.setTransaction(Transaction transaction) |
void |
IQueryProcessor.setTransaction(Transaction transaction)
Set an explicit transaction to be used by the query processor.
|
void |
QueryProcessorStub.setTransaction(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
IQueryResultSet<IEntryPacket> |
QueryTemplatePacket.read(ISpaceProxy space,
AbstractDMLQuery query,
Transaction txn,
int modifiers,
int maxResults) |
IQueryResultSet<IEntryPacket> |
QueryTemplatePacket.read(ISpaceProxy space,
Transaction txn,
long timeout,
int modifiers,
boolean ifExists,
int maxResults,
int minEntriesToWaitFor) |
IQueryResultSet<IEntryPacket> |
QueryTemplatePacket.readMultiple(ISpaceProxy space,
Transaction txn,
int maxResults,
int modifiers) |
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 |
---|---|
void |
GConnection.setTransaction(Transaction transaction)
Sets the transaction the connection will use.
|
Modifier and Type | Method and Description |
---|---|
int |
AbstractQueryExecutor.clear(QueryTemplatePacket template,
ISpaceProxy space,
Transaction txn,
int modifiers) |
int |
IQueryExecutor.clear(QueryTemplatePacket template,
ISpaceProxy space,
Transaction txn,
int modifier)
Execute clear
|
int |
AbstractQueryExecutor.count(QueryTemplatePacket template,
ISpaceProxy space,
Transaction txn,
int readModifier) |
int |
IQueryExecutor.count(QueryTemplatePacket template,
ISpaceProxy space,
Transaction txn,
int readModifier) |
void |
QueryExecutor.execute(AndNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
IQueryExecutor.execute(AndNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Execute And expression - execute both children and union the results
|
void |
JoinedQueryExecutor.execute(AndNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
QueryExecutor.execute(ExpNode expNode,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
IQueryExecutor.execute(ExpNode equalNode,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
JoinedQueryExecutor.execute(ExpNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
AbstractQueryExecutor.execute(InnerQueryNode innerQueryNode,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Executes an inner query
|
void |
IQueryExecutor.execute(InnerQueryNode innerQueryNode,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Execute inner query
|
void |
QueryExecutor.execute(InNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
IQueryExecutor.execute(InNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Execute IN expression - can be a list of simple values or an inner select query
|
void |
JoinedQueryExecutor.execute(InNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
IQueryResultSet<IEntryPacket> |
QueryExecutor.execute(ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
IQueryResultSet<IEntryPacket> |
IQueryExecutor.execute(ISpaceProxy space,
Transaction txn,
int modifiers,
int max) |
IQueryResultSet<IEntryPacket> |
JoinedQueryExecutor.execute(ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
QueryExecutor.execute(NotInNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
IQueryExecutor.execute(NotInNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
execute NOT IN query
|
void |
JoinedQueryExecutor.execute(NotInNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
QueryExecutor.execute(OrNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
IQueryExecutor.execute(OrNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Execute Or expression - execute both children and union the results
|
void |
JoinedQueryExecutor.execute(OrNode exp,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
IQueryResultSet<IEntryPacket> |
AbstractQueryExecutor.executeTemplate(QueryTemplatePacket template,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
protected boolean |
JoinedQueryExecutor.matchesExpressionTree(ExpNode root,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Traverse the binary expression tree non-recursively using a custom stack The tree has to be
traversed in postorder - the parent is traversed after its children.
|
IQueryResultSet |
AbstractQueryExecutor.readAll(ISpaceProxy space,
Transaction txn) |
IQueryResultSet<IEntryPacket> |
IQueryExecutor.readAll(ISpaceProxy space,
Transaction txn) |
protected IQueryResultSet<IEntryPacket> |
AbstractQueryExecutor.traverseExpressionTree(ExpNode root,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Traverse the binary expression tree non-recursively using a custom stack The tree has to be
traversed in postorder - the parent is traversed after its children.
|
Constructor and Description |
---|
ExecutionTask(QueryTemplatePacket packet,
ISpaceProxy space,
Transaction transaction,
int maxObjects,
int readModifier) |
Modifier and Type | Method and Description |
---|---|
void |
OrNode.accept(IQueryExecutor executor,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Accept the query executor
|
void |
ValueNode.accept(IQueryExecutor executor,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
AndNode.accept(IQueryExecutor executor,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Accept the query executor
|
void |
ExpNode.accept(IQueryExecutor executor,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Accept the query executor
|
void |
InNode.accept(IQueryExecutor executor,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Accept the query executor
|
void |
InnerQueryNode.accept(IQueryExecutor executor,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max) |
void |
NotInNode.accept(IQueryExecutor executor,
ISpaceProxy space,
Transaction txn,
int readModifier,
int max)
Accept the query executor
|
Modifier and Type | Method and Description |
---|---|
void |
QueryTableData.init(ISpaceProxy space,
Transaction txn,
AbstractDMLQuery query)
Fetch the entries from space that match this table condition
|
Modifier and Type | Method and Description |
---|---|
Transaction |
SetTransaction.getTransaction() |
Modifier and Type | Method and Description |
---|---|
void |
SetTransaction.setTransaction(Transaction transaction) |
Constructor and Description |
---|
SetTransaction(Transaction transaction) |
Modifier and Type | Field and Description |
---|---|
protected Transaction |
GSSessionImpl._tx |
Modifier and Type | Method and Description |
---|---|
protected Transaction |
GSSessionImpl.getTransaction() |
Modifier and Type | Method and Description |
---|---|
void |
XAResourceJMSImpl.action(Transaction txn) |
Modifier and Type | Field and Description |
---|---|
protected Transaction |
AbstractMap._transaction |
Modifier and Type | Method and Description |
---|---|
Transaction |
IMap.getTransaction()
Deprecated.
use explicit transaction instead
|
Transaction |
AbstractMap.getTransaction()
Returns active transaction or
null if no transaction defined. |
Modifier and Type | Method and Description |
---|---|
Object |
IMap.get(Object key,
Transaction txn,
long waitForResponse,
int readModifiers)
Returns the object that is associated with
key in this cache. |
Object |
AbstractMap.get(Object key,
Transaction txn,
long waitForResponse,
int readModifiers)
Returns the object that is associated with
key in this cache. |
protected Object |
GSMapImpl.internalGet(Object key,
Transaction txn,
long waitForResponse,
int readModifiers)
Gets the mapping for this key from this map if it is present.
|
protected abstract Object |
AbstractMap.internalGet(Object key,
Transaction txn,
long waitForResponse,
int readModifiers)
Gets the mapping for this key from this map if it is present.
|
protected Object |
GSMapImpl.internalGet(Object key,
Transaction txn,
long waitForResponse,
int readModifiers,
boolean isRemove)
Gets or Removes the mapping for this key from this map if present (optional operation).
|
protected Object |
GSMapImpl.internalPut(Object key,
Object value,
Transaction txn,
long timeToLive,
long timeout)
Puts
value to the cache with specified key and
attributes for timeToLive milliseconds to live in the cache. |
protected abstract Object |
AbstractMap.internalPut(Object key,
Object value,
Transaction txn,
long timeToLive,
long timeout) |
protected Object |
GSMapImpl.internalRemove(Object key,
Transaction txn,
long waitForResponse)
Removes the mapping for this key from this map if it is present.
|
protected abstract Object |
AbstractMap.internalRemove(Object key,
Transaction txn,
long waitForResponse)
Removes the mapping for this key from this map if it is present.
|
Object |
IMap.put(Object key,
Object value,
Transaction txn,
long timeToLive)
Puts
value to the cache with specified key for
timeToLive milliseconds to live in the cache. |
Object |
AbstractMap.put(Object key,
Object value,
Transaction txn,
long timeToLive) |
Object |
IMap.put(Object key,
Object value,
Transaction txn,
long timeToLive,
long waitForResponse)
Puts
value to the cache with specified key for
timeToLive milliseconds to live in the cache. |
Object |
AbstractMap.put(Object key,
Object value,
Transaction txn,
long timeToLive,
long timeout)
Puts
value to the cache with specified key for
timeToLive milliseconds to live in the cache. |
void |
IMap.putAll(Map map,
Transaction txn,
long timeToLive)
Copies all of the mappings from the specified map to the cache.
|
void |
AbstractMap.putAll(Map map,
Transaction txn,
long timeToLive)
Copies all of the mappings from the specified map to the cache.
|
Object |
IMap.remove(Object key,
Transaction txn,
long waitForResponse)
Removes the mapping for this
key from this cache. |
Object |
AbstractMap.remove(Object key,
Transaction txn,
long waitForResponse)
Removes the mapping for this
key from this cache. |
void |
IMap.setTransaction(Transaction transaction)
Deprecated.
use explicit transaction instead
|
void |
AbstractMap.setTransaction(Transaction transaction)
Set current transaction, all the map calls will be performed under this transaction.
|
Constructor and Description |
---|
AbstractMap(IJSpace space,
long timeToLive,
Transaction txn,
int compression,
boolean isVersioned)
AbstractMap constructor.
|
GSMapImpl(IJSpace space,
long timeToLive,
Transaction txn,
int compress)
GSMapImpl constructor.
|
GSMapImpl(IJSpace space,
Transaction txn)
GSMap constructor.
|
Modifier and Type | Method and Description |
---|---|
Transaction |
MahaloTxnBasicLease.getCreatedTransaction() |
Transaction |
TxnManagerImpl.getTransaction(long id)
Method from
TxnManager which produces a Transaction from its ID. |
Transaction |
TxnManager.getTransaction(long id)
Retrieves a
Transaction given the transaction's ID. |
Modifier and Type | Method and Description |
---|---|
void |
MahaloTxnBasicLease.setCreatedTransaction(Transaction tx) |
Constructor and Description |
---|
AbortJob(Transaction tr,
TaskManager pool,
WakeupManager wm,
ClientLog log,
com.sun.jini.mahalo.ParticipantHandle[] handles,
boolean directCall,
Object xid)
Constructs an
AbortJob |
CommitJob(Transaction tr,
TaskManager pool,
WakeupManager wm,
ClientLog log,
com.sun.jini.mahalo.ParticipantHandle[] handles,
Object xid)
Constructs an
CommitJob |
PrepareAndCommitJob(Transaction tr,
TaskManager pool,
WakeupManager wm,
ClientLog log,
com.sun.jini.mahalo.ParticipantHandle handle,
boolean directCall,
Object tid)
Constructs a
PrepareAndCommitJob . |
PrepareJob(Transaction tr,
TaskManager pool,
WakeupManager wm,
ClientLog log,
com.sun.jini.mahalo.ParticipantHandle[] handles,
Object xid,
ConcurrentMap<String,IDirectSpaceProxy> proxiesMap)
Constructs an
PrepareJob |
Modifier and Type | Interface and Description |
---|---|
interface |
ManagedTransaction
additional methods which relates to the underlying transaction manager
|
interface |
NestableTransaction
Interface for classes representing nestable transactions returned by
NestableTransactionManager servers for use with transaction participants that
implement the default transaction semantics. |
Modifier and Type | Field and Description |
---|---|
Transaction |
Transaction.Created.transaction
The transaction.
|
Modifier and Type | Method and Description |
---|---|
void |
ITransactionLease.setCreatedTransaction(Transaction tx) |
Constructor and Description |
---|
Created(Transaction transaction,
Lease lease)
Simple constructor.
|
Modifier and Type | Class and Description |
---|---|
class |
NestableServerTransaction
Class implementing the
NestableTransaction interface, for use with transaction
participants that implement the default transaction semantics. |
class |
ServerTransaction
Class implementing the
Transaction interface, for use with transaction participants
that implement the default transaction semantics. |
Modifier and Type | Method and Description |
---|---|
EventRegistration |
JavaSpace.notify(Entry tmpl,
Transaction txn,
RemoteEventListener listener,
long lease,
MarshalledObject handback)
When entries are written that match this template notify the given
listener with
a RemoteEvent that includes the handback object. |
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. |
Lease |
JavaSpace.write(Entry entry,
Transaction txn,
long lease)
Write a new entry into the space.
|
Modifier and Type | Method and Description |
---|---|
Transaction |
DefaultGigaSpace.getCurrentTransaction() |
Transaction |
GigaMap.getCurrentTransaction()
Returns the current running transaction.
|
Transaction |
GigaSpace.getCurrentTransaction()
Returns the current running transaction.
|
Transaction |
DefaultGigaMap.getCurrentTransaction() |
Modifier and Type | Method and Description |
---|---|
<T> AsyncFuture<T> |
DefaultGigaSpace.wrapFuture(AsyncFuture<T> future,
Transaction tx) |
<T> AsyncFutureListener<T> |
DefaultGigaSpace.wrapListener(AsyncFutureListener<T> listener,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
T |
InternalSpaceTaskWrapper.execute(IJSpace space,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
<T> AsyncFuture<T> |
InternalGigaSpace.wrapFuture(AsyncFuture<T> future,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
Transaction |
LockHandle.getTransaction()
Returns the transaction representing the lock on the given key.
|
Modifier and Type | Method and Description |
---|---|
Transaction |
DefaultTransactionProvider.getCurrentTransaction() |
Constructor and Description |
---|
InternalAsyncFuture(AsyncFuture<T> future,
GigaSpace gigaSpace,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
Transaction |
JiniTransactionHolder.getTransaction()
Returns the Jini transaction object.
|
Transaction |
AbstractJiniTransactionManager.JiniTransactionObject.getTransaction() |
Modifier and Type | Method and Description |
---|---|
static boolean |
ExistingJiniTransactionManager.bindExistingTransaction(Transaction transaction)
Same as
ExistingJiniTransactionManager.bindExistingTransaction(net.jini.core.transaction.Transaction, boolean,
boolean) with rollback and commit flags set to true (disabled). |
static boolean |
ExistingJiniTransactionManager.bindExistingTransaction(Transaction transaction,
boolean disableCommit,
boolean disableRollback)
Binds the provided Jini
Transaction , which means that any
operation under the current thread by GigaSpace will be performed
under it. |
Modifier and Type | Method and Description |
---|---|
Transaction |
MuleXATransactionProvider.getCurrentTransaction() |
Copyright © GigaSpaces.