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. |
Modifier and Type | Method and Description |
---|---|
void |
SpaceIteratorBatchResultProvider.triggerSinglePartitionBatchTask(int partitionId,
int batchNumber) |
Modifier and Type | Method and Description |
---|---|
static ITransactionManagerProvider |
TransactionManagerProviderFactory.newInstance(IJSpace space,
TransactionManagerConfiguration transactionManagerConfiguration) |
Constructor and Description |
---|
DistributedTransactionManagerProvider() |
LookupDistributedTransactionManagerProvider(LookupTransactionManagerConfiguration config) |
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 |
---|---|
AggregationResult |
ISpaceProxy.aggregate(Object template,
AggregationSet aggregationSet,
Transaction txn,
int readModifiers) |
AggregationResult |
AbstractSpaceProxy.aggregate(Object template,
AggregationSet aggregationSet,
Transaction txn,
int readModifiers) |
<T> ChangeResult<T> |
ISpaceProxy.change(Object template,
ChangeSet changeSet,
Transaction txn,
long timeout,
ChangeModifiers modifiers)
Change entry in space
|
<T> ChangeResult<T> |
AbstractSpaceProxy.change(Object template,
ChangeSet changeSet,
Transaction txn,
long timeout,
ChangeModifiers modifiers) |
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 |
ISpaceProxy.execute(SpaceTask task,
Object routing,
Transaction tx,
AsyncFutureListener listener)
Executes a task on a single space.
|
AsyncFuture |
AbstractSpaceProxy.execute(SpaceTask task,
Object routing,
Transaction tx,
AsyncFutureListener listener) |
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 |
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) |
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[] |
ISpaceProxy.writeMultiple(Object[] objects,
Transaction txn,
long lease,
long[] leases,
long timeout,
int modifiers) |
LeaseContext<?>[] |
AbstractSpaceProxy.writeMultiple(Object[] objects,
Transaction txn,
long lease,
long[] leases,
long timeout,
int modifiers) |
Modifier and Type | Method and Description |
---|---|
AggregationResult |
AbstractSpaceProxyActionManager.aggregate(Object query,
AggregationSet aggregationSet,
Transaction txn,
int modifiers) |
AggregationResult |
SpaceProxyImplAggregateAction.aggregate(SpaceProxyImpl spaceProxy,
AggregateProxyActionInfo actionInfo) |
abstract AggregationResult |
AggregateProxyAction.aggregate(TSpaceProxy spaceProxy,
AggregateProxyActionInfo actionInfo) |
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) |
<T> ChangeResult<T> |
AbstractSpaceProxyActionManager.change(Object template,
ChangeSet changeSet,
Transaction txn,
long timeout,
ChangeModifiers modifiers) |
ChangeResult<?> |
SpaceProxyImplChangeAction.change(SpaceProxyImpl spaceProxy,
ChangeProxyActionInfo actionInfo) |
abstract ChangeResult<?> |
ChangeProxyAction.change(TSpaceProxy spaceProxy,
ChangeProxyActionInfo actionInfo) |
int |
AbstractSpaceProxyActionManager.count(Object template,
Transaction txn,
int modifiers) |
int |
SpaceProxyImplCountClearAction.execute(SpaceProxyImpl spaceProxy,
CountClearProxyActionInfo actionInfo) |
AsyncFuture |
SpaceProxyImplAdminAction.execute(SpaceProxyImpl spaceProxy,
SpaceTask task,
Object routing,
Transaction txn,
AsyncFutureListener listener) |
abstract int |
CountClearProxyAction.execute(TSpaceProxy spaceProxy,
CountClearProxyActionInfo actionInfo) |
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.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.
|
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) |
LeaseContext<?> |
AbstractSpaceProxyActionManager.write(Object entry,
Transaction txn,
long lease,
long timeout,
int modifiers) |
LeaseContext<?> |
SpaceProxyImplWriteAction.write(SpaceProxyImpl spaceProxy,
WriteProxyActionInfo actionInfo) |
abstract LeaseContext<?> |
WriteProxyAction.write(TSpaceProxy spaceProxy,
WriteProxyActionInfo actionInfo) |
LeaseContext<?>[] |
AbstractSpaceProxyActionManager.writeMultiple(Object[] objects,
Transaction txn,
long lease,
long[] leases,
long timeout,
int modifiers) |
LeaseContext<?>[] |
SpaceProxyImplWriteAction.writeMultiple(SpaceProxyImpl spaceProxy,
WriteMultipleProxyActionInfo actionInfo) |
abstract LeaseContext<?>[] |
WriteProxyAction.writeMultiple(TSpaceProxy spaceProxy,
WriteMultipleProxyActionInfo actionInfo) |
Modifier and Type | Method and Description |
---|---|
ChangeResult<?> |
ChangeEntriesSpaceOperationRequest.getFinalResult() |
IEntryPacket[] |
ReadTakeEntriesSpaceOperationRequest.getFinalResult() |
IEntryPacket |
ReadTakeEntrySpaceOperationRequest.getFinalResult() |
int |
CountClearEntriesSpaceOperationRequest.getFinalResult() |
ReadTakeEntriesByIdsSpaceOperationResult |
ReadTakeEntriesByIdsSpaceOperationRequest.getFinalResult() |
ReadTakeEntriesUidsResult |
ReadTakeEntriesUidsSpaceOperationRequest.getFinalResult() |
AggregationResult |
AggregateEntriesSpaceOperationRequest.getFinalResult(IJSpace spaceProxy,
ITemplatePacket queryPacket,
boolean returnEntryPacket) |
void |
AbortPreparedTransactionSpaceOperationResult.processExecutionException() |
void |
CountClearEntriesSpaceOperationResult.processExecutionException() |
void |
PrepareAndCommitTransactionSpaceOperationResult.processExecutionException() |
void |
ReadTakeEntriesByIdsSpaceOperationResult.processExecutionException() |
void |
ReadTakeEntriesSpaceOperationResult.processExecutionException() |
void |
ReadTakeEntriesUidsSpaceOperationResult.processExecutionException() |
void |
ChangeEntriesSpaceOperationResult.processExecutionException() |
void |
CommitPreparedTransactionSpaceOperationResult.processExecutionException() |
void |
WriteEntrySpaceOperationResult.processExecutionException() |
Modifier and Type | Method and Description |
---|---|
protected ExtendedAnswerHolder |
AbstractSpaceReplicationEntryEventHandler.executeUpdateOperation(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
IEntryPacket previousEntry,
boolean partialUpdate,
boolean overrideVersion,
long lease,
boolean twoPhaseCommit,
int updateModifiers) |
protected ExtendedAnswerHolder |
PrimaryBackupSpaceReplicationEvictionProtectionEntryEventHandler.executeUpdateOperation(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
IEntryPacket previousEntry,
boolean partialUpdate,
boolean overrideVersion,
long lease,
boolean twoPhaseCommit,
int updateModifiers) |
protected void |
AbstractSpaceReplicationEntryEventHandler.removeEntryFromSpace(IReplicationInContext context,
Transaction txn,
ITemplatePacket template,
boolean twoPhaseCommit) |
protected void |
PrimaryBackupSpaceReplicationEntryEventHandler.removeEntryFromSpace(IReplicationInContext context,
Transaction txn,
ITemplatePacket template,
boolean twoPhaseCommit) |
protected void |
BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.removeEntryFromSpace(IReplicationInContext context,
Transaction txn,
ITemplatePacket template,
boolean twoPhaseCommit) |
protected void |
AbstractSpaceReplicationEntryEventHandler.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 |
BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.updateEntryInSpace(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
IEntryPacket previousEntry,
boolean partialUpdate,
boolean overrideVersion,
long lease,
boolean twoPhaseCommit) |
protected abstract ExtendedAnswerHolder |
AbstractSpaceReplicationEntryEventHandler.updateOrWrite(IReplicationInContext context,
Transaction txn,
IEntryPacket entry,
long lease,
int modifiers) |
protected ExtendedAnswerHolder |
PrimaryBackupSpaceReplicationEntryEventHandler.updateOrWrite(IReplicationInContext context,
Transaction transaction,
IEntryPacket entryPacket,
long lease,
int updateModifiers) |
protected ExtendedAnswerHolder |
ActiveActiveSpaceReplicationEntryEventHandler.updateOrWrite(IReplicationInContext context,
Transaction transaction,
IEntryPacket entryPacket,
long lease,
int updateModifiers) |
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) |
XtnEntry |
SpaceEngine.attachToXtn(ServerTransaction txn,
boolean fromReplication)
Join the specified transaction, if not already joined.
|
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) |
void |
SpaceEngine.executeOnMatchingEntries(Context context,
ITemplateHolder template,
boolean makeWaitForInfo)
Searches the engine for a matching entry using the BFS tree of the specified template.
|
IEntryHolder |
SpaceEngine.getMatchedEntryAndOperateSA(Context context,
ITemplateHolder template,
boolean makeWaitForInfo,
boolean useSCN)
Searches the engine for a matching entry using the BFS tree of the specified template.
|
ServerIteratorAnswerHolder |
SpaceImpl.getNextBatchFromServerIterator(ITemplatePacket template,
SpaceContext sc,
int modifiers,
ServerIteratorRequestInfo serverIteratorRequestInfo) |
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 |
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) |
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,
ServerIteratorRequestInfo serverIteratorRequestInfo) |
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.
|
ExtendedAnswerHolder |
SpaceEngine.updateOrWrite(UpdateOrWriteContext ctx,
boolean newRouter) |
ExtendedAnswerHolder |
SpaceEngine.updateOrWrite(UpdateOrWriteContext ctx,
boolean fromReplication,
boolean origin,
boolean newRouter) |
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 | Class and Description |
---|---|
class |
SyncHybridTransactionException |
Modifier and Type | Method and Description |
---|---|
ResponsePacket |
RequestPacketV3.accept(QueryHandler handler,
QuerySession session) |
Modifier and Type | Method and Description |
---|---|
AnswerPacket |
AnswerHolder.getResult() |
void |
AnswerHolder.throwExceptionIfExists() |
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 |
---|---|
XtnEntry |
TransactionHandler.attachToXtnGranular(ServerTransaction txn,
boolean fromReplication)
Join the specified transaction, if not already joined.
|
void |
TransactionHandler.checkTransactionDisconnection(OperationID opid,
ServerTransaction txn) |
XtnEntry |
TransactionHandler.getTransactionEntry(ServerTransaction txn)
Get the transaction entry for given transaction.
|
Modifier and Type | Method and Description |
---|---|
ResponsePacket |
RequestPacket.accept(QueryHandler handler,
QuerySession session) |
ITransactionManagerProvider |
QueryHandler.getTransactionManagerProvider() |
ResponsePacket |
QueryHandler.visit(RequestPacket request,
QuerySession session) |
ResponsePacket |
QueryHandler.visit(RequestPacketV3 request,
QuerySession session) |
ResponsePacket |
QueryHandler.visit(SetAutoCommitRequest request,
QuerySession session)
Handle set auto commit [on off] request
|
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 |
AbstractQueryExecutor.clear(QueryTemplatePacket template,
ISpaceProxy space,
Transaction txn,
int modifiers) |
int |
IQueryExecutor.clear(QueryTemplatePacket template,
ISpaceProxy space,
Transaction txn,
int modifier)
Execute clear
|
Modifier and Type | Method and Description |
---|---|
ResponsePacket |
SetAutoCommitRequest.accept(QueryHandler handler,
QuerySession session) |
ResponsePacket |
SetTransaction.accept(QueryHandler handler,
QuerySession session) |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
CannotAbortException
Exception thrown when a transaction cannot abort because it has already already decided to
commit.
|
class |
CannotCommitDistributedException
Exception thrown when a transaction cannot commit on multiple partitions because it has already
aborted or must now be aborted.
|
class |
CannotCommitException
Exception thrown when a transaction cannot commit because it has already aborted or must now be
aborted.
|
class |
CannotJoinException
Exception thrown when a transaction cannot be joined because it is no longer active.
|
class |
CannotNestException
Exception thrown when an object does not support nested transactions.
|
class |
TimeoutExpiredException
Exception thrown when a transaction timeout has expired.
|
class |
UnknownTransactionException
Exception thrown when a transaction is not recognized as a valid or known transaction.
|
Modifier and Type | Class and Description |
---|---|
class |
CrashCountException
Exception thrown when a transaction cannot be joined because the participant's current crash
count is different from the crash count the manager received in a previous join by that
participant.
|
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 |
---|---|
void |
ScaleManager.scaleIn(DefaultProcessingUnit pu,
int factor,
InternalAdminDriver driver) |
void |
ScaleManager.scaleOutUnSafe(DefaultProcessingUnit pu,
int factor,
String memory,
String cpu,
InternalAdminDriver driver) |
Constructor and Description |
---|
InactiveTransactionException(TransactionException e) |
InvalidTransactionUsageException(TransactionException e) |
TransactionDataAccessException(TransactionException e) |
Copyright © GigaSpaces.