public class DefaultGigaSpace extends Object implements GigaSpace, InternalGigaSpace
GigaSpace
. Constructed with IJSpace
,
TransactionProvider
and ExceptionTranslator
. Operations are delegated to IJSpace
with transactions acquired using TransactionProvider
. Any exceptions thrown during the operations
are translated using ExceptionTranslator
.
Allows to set default timeouts for read and take operations and default lease for write operation.
Constructor and Description |
---|
DefaultGigaSpace(GigaSpaceConfigurer configurer)
Constructs a new DefaultGigaSpace implementation.
|
Modifier and Type | Method and Description |
---|---|
<T> AggregationResult |
aggregate(ISpaceQuery<T> query,
AggregationSet aggregationSet)
Executes the specified query along with the specified aggregations collocated at the space.
|
<T> AggregationResult |
aggregate(ISpaceQuery<T> query,
AggregationSet aggregationSet,
ReadModifiers readModifiers) |
<T> Future<ChangeResult<T>> |
asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet)
Changes existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
<T> Future<ChangeResult<T>> |
asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
<T> Future<ChangeResult<T>> |
asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet,
ChangeModifiers modifiers)
Changes an existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
<T> Future<ChangeResult<T>> |
asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet,
ChangeModifiers modifiers,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
<T> Future<ChangeResult<T>> |
asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet,
ChangeModifiers modifiers,
long timeout)
Changes existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
<T> Future<ChangeResult<T>> |
asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet,
ChangeModifiers modifiers,
long timeout,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
<T> Future<ChangeResult<T>> |
asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet,
long timeout)
Changes existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
<T> Future<ChangeResult<T>> |
asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet,
long timeout,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
<T> Future<ChangeResult<T>> |
asyncChange(T template,
ChangeSet changeSet)
Changes existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
<T> Future<ChangeResult<T>> |
asyncChange(T template,
ChangeSet changeSet,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
<T> Future<ChangeResult<T>> |
asyncChange(T template,
ChangeSet changeSet,
ChangeModifiers modifiers)
Changes an existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
<T> Future<ChangeResult<T>> |
asyncChange(T template,
ChangeSet changeSet,
ChangeModifiers modifiers,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
<T> Future<ChangeResult<T>> |
asyncChange(T template,
ChangeSet changeSet,
ChangeModifiers modifiers,
long timeout)
Changes existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
<T> Future<ChangeResult<T>> |
asyncChange(T template,
ChangeSet changeSet,
ChangeModifiers modifiers,
long timeout,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
<T> Future<ChangeResult<T>> |
asyncChange(T template,
ChangeSet changeSet,
long timeout)
Changes existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
<T> Future<ChangeResult<T>> |
asyncChange(T template,
ChangeSet changeSet,
long timeout,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a
future.
|
AsyncFuture<SpaceDataSourceLoadResult> |
asyncLoad(SpaceDataSourceLoadRequest spaceDataSourceLoadRequest)
Loads data from a
SpaceDataSource on demand
The Space data source is created with SpaceDataSourceFactory
Loaded data can be adapted using the SpaceTypeSchemaAdapter |
<T> AsyncFuture<T> |
asyncRead(ISpaceQuery<T> template)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncRead(ISpaceQuery<T> template,
AsyncFutureListener<T> listener)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncRead(ISpaceQuery<T> template,
long timeout)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncRead(ISpaceQuery<T> template,
long timeout,
AsyncFutureListener<T> listener)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncRead(ISpaceQuery<T> template,
long timeout,
ReadModifiers modifiers)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncRead(ISpaceQuery<T> template,
long timeout,
ReadModifiers modifiers,
AsyncFutureListener<T> listener)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncRead(T template)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncRead(T template,
AsyncFutureListener<T> listener)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncRead(T template,
long timeout)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncRead(T template,
long timeout,
AsyncFutureListener<T> listener)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncRead(T template,
long timeout,
ReadModifiers modifiers)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncRead(T template,
long timeout,
ReadModifiers modifiers,
AsyncFutureListener<T> listener)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncTake(ISpaceQuery<T> template)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncTake(ISpaceQuery<T> template,
AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncTake(ISpaceQuery<T> template,
long timeout)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncTake(ISpaceQuery<T> template,
long timeout,
AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncTake(ISpaceQuery<T> template,
long timeout,
TakeModifiers modifiers)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncTake(ISpaceQuery<T> template,
long timeout,
TakeModifiers modifiers,
AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncTake(T template)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncTake(T template,
AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncTake(T template,
long timeout)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncTake(T template,
long timeout,
AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncTake(T template,
long timeout,
TakeModifiers modifiers)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
asyncTake(T template,
long timeout,
TakeModifiers modifiers,
AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> ChangeResult<T> |
change(ISpaceQuery<T> query,
ChangeSet changeSet)
Changes existing objects in space, returning a change result which provides details of the
operation affect.
|
<T> ChangeResult<T> |
change(ISpaceQuery<T> query,
ChangeSet changeSet,
ChangeModifiers modifiers)
Changes existing objects in space, returning a change result which provides details of the
operation affect.
|
<T> ChangeResult<T> |
change(ISpaceQuery<T> query,
ChangeSet changeSet,
ChangeModifiers modifiers,
long timeout)
Changes existing objects in space, returning a change result which provides details of the
operation affect.
|
<T> ChangeResult<T> |
change(ISpaceQuery<T> query,
ChangeSet changeSet,
long timeout)
Changes existing objects in space, returning a change result which provides details of the
operation affect.
|
<T> ChangeResult<T> |
change(T template,
ChangeSet changeSet)
Changes existing objects in space, returning a change result which provides details of the
operation affect.
|
<T> ChangeResult<T> |
change(T template,
ChangeSet changeSet,
ChangeModifiers modifiers)
Changes existing objects in space, returning a change result which provides details of the
operation affect.
|
<T> ChangeResult<T> |
change(T template,
ChangeSet changeSet,
ChangeModifiers modifiers,
long timeout)
Changes existing objects in space, returning a change result which provides details of the
operation affect.
|
<T> ChangeResult<T> |
change(T template,
ChangeSet changeSet,
long timeout)
Changes existing objects in space, returning a change result which provides details of the
operation affect.
|
void |
clear(Object template)
Removes the entries that match the specified template and the specified transaction from this
space.
|
int |
clear(Object template,
ClearModifiers modifiers)
Removes the entries that match the specified template and the specified transaction from this
space.
|
void |
close() |
int |
count(Object template)
Count any matching entry from the space.
|
int |
count(Object template,
CountModifiers modifiers)
Count any matching entries from the space.
|
<T extends Serializable,R> |
distExecute(DistributedTask<T,R> task,
AsyncFutureListener<R> listener) |
<T extends Serializable,R> |
execute(DistributedTask<T,R> task)
Executes the task on all the primary space nodes within the cluster (broadcast).
|
<T extends Serializable,R> |
execute(DistributedTask<T,R> task,
AsyncFutureListener<R> listener) |
<T extends Serializable,R> |
execute(DistributedTask<T,R> task,
Object... routings)
Executes a task on all the nodes that correspond to the list of routing values.
|
<T extends Serializable> |
execute(Task<T> task)
Executes a task on a specific space node.
|
<T extends Serializable> |
execute(Task<T> task,
AsyncFutureListener<T> listener)
Executes a task on a specific space node.
|
<T extends Serializable> |
execute(Task<T> task,
Object routing)
Executes a task on a specific space node.
|
<T extends Serializable> |
execute(Task<T> task,
Object routing,
AsyncFutureListener<T> listener)
Executes a task on a specific space node.
|
<T extends Serializable,R> |
executorBuilder(AsyncResultsReducer<T,R> reducer)
Constructs an executor builder allowing to accumulate different tasks required to be executed
into a single execute mechanism with all the results reduced by the reducer provided.
|
GigaSpace |
getClustered()
Returns a clustered view of this
GigaSpace instance. |
Transaction |
getCurrentTransaction()
Returns the current running transaction.
|
ChangeModifiers |
getDefaultChangeModifiers()
Gets the default
ChangeModifiers set during this GigaSpace configuration. |
ClearModifiers |
getDefaultClearModifiers()
Gets the default
ClearModifiers set during this GigaSpace configuration. |
CountModifiers |
getDefaultCountModifiers()
Gets the default
CountModifiers set during this GigaSpace configuration. |
int |
getDefaultIsolationLevel()
Gets the defaultIsolationLevel.
|
ReadModifiers |
getDefaultReadModifiers()
Gets the default
ReadModifiers set during this GigaSpace configuration. |
long |
getDefaultReadTimeout()
Gets the default read timeout when executing
read(Object) or readIfExists(Object) operations. |
TakeModifiers |
getDefaultTakeModifiers()
Gets the default
TakeModifiers set during this GigaSpace configuration. |
long |
getDefaultTakeTimeout()
Gets the default take timeout when executing
take(Object) or takeIfExists(Object) operations. |
long |
getDefaultWriteLease()
Gets the default write lease when executing
write(Object) . |
WriteModifiers |
getDefaultWriteModifiers()
Gets the default
WriteModifiers set during this GigaSpace configuration. |
ExceptionTranslator |
getExceptionTranslator()
Returns the exception translator associated with this GigaSpace instance.
|
String |
getName()
Returns the name of the GigaSpace.
|
IJSpace |
getSpace()
Returns the
IJSpace used by this GigaSpace implementation to delegate different
space operations. |
String |
getSpaceName()
Returns the space name.
|
TransactionProvider |
getTxProvider()
Returns the transaction provider allowing to access the current running transaction.
|
GigaSpaceTypeManager |
getTypeManager()
Gets the type manager of this GigaSpace instance.
|
boolean |
isSecured()
Returns wether or not this space is secured.
|
<T> SpaceIterator<T> |
iterator(ISpaceQuery<T> template)
Returns an iterator over the entries in the space which match the specified template.
|
<T> SpaceIterator<T> |
iterator(ISpaceQuery<T> template,
int batchSize)
Returns an iterator over the entries in the space which match the specified template.
|
<T> SpaceIterator<T> |
iterator(ISpaceQuery<T> template,
int batchSize,
ReadModifiers modifiers)
Returns an iterator over the entries in the space which match the specified template.
|
<T> SpaceIterator<T> |
iterator(ISpaceQuery<T> template,
SpaceIteratorConfiguration spaceIteratorConfiguration)
Returns an iterator over the entries in the space which match the specified template.
|
<T> SpaceIterator<T> |
iterator(T template)
Returns an iterator over the entries in the space which match the specified template.
|
<T> SpaceIterator<T> |
iterator(T template,
int batchSize)
Returns an iterator over the entries in the space which match the specified template.
|
<T> SpaceIterator<T> |
iterator(T template,
int batchSize,
ReadModifiers modifiers)
Returns an iterator over the entries in the space which match the specified template.
|
<T> SpaceIterator<T> |
iterator(T template,
SpaceIteratorConfiguration spaceIteratorConfiguration)
Returns an iterator over the entries in the space which match the specified template.
|
DataEventSession |
newDataEventSession()
Creates a new DataEventSession with the default configuration.
|
DataEventSession |
newDataEventSession(EventSessionConfig config)
Creates a new DataEventSession with the specified configuration.
|
<T> ISpaceQuery<T> |
prepareTemplate(Object template)
Translates the template object into pre-processed packet which will be sent to the space.
|
<T> T |
read(ISpaceQuery<T> template)
Read any matching object from the space, blocking until one exists.
|
<T> T |
read(ISpaceQuery<T> template,
long timeout)
Read any matching object from the space, blocking until one exists.
|
<T> T |
read(ISpaceQuery<T> template,
long timeout,
ReadModifiers modifiers)
Read any matching object from the space, blocking until one exists.
|
<T> T |
read(T template)
Read any matching object from the space, blocking until one exists.
|
<T> T |
read(T template,
long timeout)
Read any matching object from the space, blocking until one exists.
|
<T> T |
read(T template,
long timeout,
ReadModifiers modifiers)
Read any matching object from the space, blocking until one exists.
|
<T> T |
readById(Class<T> clazz,
Object id)
Read an object from the space matching its id and the class.
|
<T> T |
readById(Class<T> clazz,
Object id,
Object routing)
Read an object from the space matching its id, the class and the routing value.
|
<T> T |
readById(Class<T> clazz,
Object id,
Object routing,
long timeout)
Read an object from the space matching its id, the class and the routing value.
|
<T> T |
readById(Class<T> clazz,
Object id,
Object routing,
long timeout,
ReadModifiers modifiers)
Read an object from the space matching its id, the class and the routing value.
|
<T> T |
readById(IdQuery<T> query)
Read an object from the space matching the specified id query.
|
<T> T |
readById(IdQuery<T> query,
long timeout)
Read an object from the space matching the specified id query.
|
<T> T |
readById(IdQuery<T> query,
long timeout,
ReadModifiers modifiers)
Read an object from the space matching the specified id query.
|
<T> ReadByIdsResult<T> |
readByIds(Class<T> clazz,
Object[] ids)
Read objects from the space matching their IDs and the specified class.
|
<T> ReadByIdsResult<T> |
readByIds(Class<T> clazz,
Object[] ids,
Object routing)
Read objects from the space matching their IDs, the specified class and routing key.
|
<T> ReadByIdsResult<T> |
readByIds(Class<T> clazz,
Object[] ids,
Object[] routings)
Read objects from the space matching their IDs, the specified class and the routing keys.
|
<T> ReadByIdsResult<T> |
readByIds(Class<T> clazz,
Object[] ids,
Object[] routings,
ReadModifiers modifiers)
Read objects from the space matching their IDs, the specified class and the routing keys,
with the provided
ReadModifiers . |
<T> ReadByIdsResult<T> |
readByIds(Class<T> clazz,
Object[] ids,
Object routing,
ReadModifiers modifiers)
Read objects from the space matching their IDs, the specified class type and routing key,
with the provided
ReadModifiers . |
<T> ReadByIdsResult<T> |
readByIds(IdsQuery<T> query)
Read objects from the space matching the specified IDs query.
|
<T> ReadByIdsResult<T> |
readByIds(IdsQuery<T> query,
ReadModifiers modifiers)
Read objects from the space matching the specified IDs query, with the provided
ReadModifiers . |
<T> T |
readIfExists(ISpaceQuery<T> template)
Read any matching object from the space, returning
null if there currently is
none. |
<T> T |
readIfExists(ISpaceQuery<T> template,
long timeout)
Read any matching object from the space, returning
null if there currently is
none. |
<T> T |
readIfExists(ISpaceQuery<T> template,
long timeout,
ReadModifiers modifiers)
Read any matching object from the space, returning
null if there currently is
none. |
<T> T |
readIfExists(T template)
Read any matching object from the space, returning
null if there currently is
none. |
<T> T |
readIfExists(T template,
long timeout)
Read any matching object from the space, returning
null if there currently is
none. |
<T> T |
readIfExists(T template,
long timeout,
ReadModifiers modifiers)
Read any matching object from the space, returning
null if there currently is
none. |
<T> T |
readIfExistsById(Class<T> clazz,
Object id)
Read an object from the space matching its id and the class.
|
<T> T |
readIfExistsById(Class<T> clazz,
Object id,
Object routing)
Read an object from the space matching its id, the class and the routing value.
|
<T> T |
readIfExistsById(Class<T> clazz,
Object id,
Object routing,
long timeout)
Read an object from the space matching its id, the class and the routing value.
|
<T> T |
readIfExistsById(Class<T> clazz,
Object id,
Object routing,
long timeout,
ReadModifiers modifiers)
Read an object from the space matching its id, the class and the routing value.
|
<T> T |
readIfExistsById(IdQuery<T> query)
Read an object from the space matching the specified id query.
|
<T> T |
readIfExistsById(IdQuery<T> query,
long timeout)
Read an object from the space matching the specified id query.
|
<T> T |
readIfExistsById(IdQuery<T> query,
long timeout,
ReadModifiers modifiers)
Read an object from the space matching the specified id query.
|
<T> T[] |
readMultiple(ISpaceQuery<T> template)
Read any matching entries from the space.
|
<T> T[] |
readMultiple(ISpaceQuery<T> template,
int maxEntries)
Read any matching entries from the space.
|
<T> T[] |
readMultiple(ISpaceQuery<T> template,
int maxEntries,
ReadModifiers modifiers)
Read any matching entries from the space.
|
<T> T[] |
readMultiple(T template)
Read any matching entries from the space.
|
<T> T[] |
readMultiple(T template,
int maxEntries)
Read any matching entries from the space.
|
<T> T[] |
readMultiple(T template,
int maxEntries,
ReadModifiers modifiers)
Read any matching entries from the space.
|
void |
setDefaultChangeModifiers(ChangeModifiers modifiers)
Sets the default
ChangeModifiers when excecution change(Object, ChangeSet) |
void |
setDefaultClearModifiers(ClearModifiers modifiers)
Sets the default
ClearModifiers when excecution write(Object) |
void |
setDefaultCountModifiers(CountModifiers modifiers)
Sets the default
CountModifiers when excecution count(Object) |
void |
setDefaultReadModifiers(ReadModifiers modifiers)
Sets the default
ReadModifiers when excecution read(Object) |
void |
setDefaultReadTimeout(long defaultReadTimeout)
Sets the default read timeout when executing
read(Object) or readIfExists(Object) operations. |
void |
setDefaultTakeModifiers(TakeModifiers modifiers)
Sets the default
TakeModifiers when excecution take(Object) |
void |
setDefaultTakeTimeout(long defaultTakeTimeout)
Sets the default take timeout when executing
take(Object) or takeIfExists(Object) operations. |
void |
setDefaultWriteLease(long defaultWriteLease)
Sets the default write lease when executing
write(Object) . |
void |
setDefaultWriteModifiers(WriteModifiers modifiers)
Sets the default
WriteModifiers when excecution write(Object) |
void |
setMVCCGenerationsState(MVCCGenerationsState generationsState) |
void |
setName(String name) |
void |
setQuiesceToken(QuiesceToken token) |
<T> ISpaceQuery<T> |
snapshot(Object entry)
The process of serializing an entry for transmission to a JavaSpaces service will be
identical if the same entry is used twice.
|
<T> T |
take(ISpaceQuery<T> template)
Take (remove) any matching entry from the space, blocking until one exists.
|
<T> T |
take(ISpaceQuery<T> template,
long timeout)
Take (remove) any matching entry from the space, blocking until one exists.
|
<T> T |
take(ISpaceQuery<T> template,
long timeout,
TakeModifiers modifiers)
Take (remove) any matching entry from the space, blocking until one exists.
|
<T> T |
take(T template)
Take (remove) any matching entry from the space, blocking until one exists.
|
<T> T |
take(T template,
long timeout)
Take (remove) any matching entry from the space, blocking until one exists.
|
<T> T |
take(T template,
long timeout,
TakeModifiers modifiers)
Take (remove) any matching entry from the space, blocking until one exists.
|
<T> T |
takeById(Class<T> clazz,
Object id)
Take (remove) an object from the space matching its id and the class.
|
<T> T |
takeById(Class<T> clazz,
Object id,
Object routing)
Take (remove) an object from the space matching its id, the class and the routing value.
|
<T> T |
takeById(Class<T> clazz,
Object id,
Object routing,
long timeout)
Take (remove) an object from the space matching its id, the class and the routing value.
|
<T> T |
takeById(Class<T> clazz,
Object id,
Object routing,
long timeout,
TakeModifiers modifiers)
Take (remove) an object from the space matching its id, the class and the routing value.
|
<T> T |
takeById(IdQuery<T> query)
Take (remove) an object from the space matching the specified id query.
|
<T> T |
takeById(IdQuery<T> query,
long timeout)
Take (remove) an object from the space matching the specified id query.
|
<T> T |
takeById(IdQuery<T> query,
long timeout,
TakeModifiers modifiers)
Take (remove) an object from the space matching the specified id query.
|
<T> TakeByIdsResult<T> |
takeByIds(Class<T> clazz,
Object[] ids)
Take (remove) objects from the space matching their IDs and the specified class.
|
<T> TakeByIdsResult<T> |
takeByIds(Class<T> clazz,
Object[] ids,
Object routing)
Take (remove) objects from the space matching their IDs, the specified class and routing key.
|
<T> TakeByIdsResult<T> |
takeByIds(Class<T> clazz,
Object[] ids,
Object[] routings)
Take (remove) objects from the space matching their IDs, the specified class and the routing
keys.
|
<T> TakeByIdsResult<T> |
takeByIds(Class<T> clazz,
Object[] ids,
Object[] routings,
TakeModifiers modifiers)
Take (remove) objects from the space matching their IDs, the specified class and the routing
keys, with the provided
ReadModifiers . |
<T> TakeByIdsResult<T> |
takeByIds(Class<T> clazz,
Object[] ids,
Object routing,
TakeModifiers modifiers)
Take (remove) objects from the space matching their IDs, the specified class type and routing
key, with the provided
ReadModifiers . |
<T> TakeByIdsResult<T> |
takeByIds(IdsQuery<T> query)
Take (remove) objects from the space matching the specified IDs query.
|
<T> TakeByIdsResult<T> |
takeByIds(IdsQuery<T> query,
TakeModifiers modifiers)
Take (remove) objects from the space matching the specified IDs query, with the provided
ReadModifiers . |
<T> T |
takeIfExists(ISpaceQuery<T> template)
Take (remove) any matching entry from the space, returning
null if there
currently is none. |
<T> T |
takeIfExists(ISpaceQuery<T> template,
long timeout)
Take (remove) any matching entry from the space, returning
null if there
currently is none. |
<T> T |
takeIfExists(ISpaceQuery<T> template,
long timeout,
TakeModifiers modifiers)
Take (remove) any matching entry from the space, returning
null if there
currently is none. |
<T> T |
takeIfExists(T template)
Take (remove) any matching entry from the space, returning
null if there
currently is none. |
<T> T |
takeIfExists(T template,
long timeout)
Take (remove) any matching entry from the space, returning
null if there
currently is none. |
<T> T |
takeIfExists(T template,
long timeout,
TakeModifiers modifiers)
Take (remove) any matching entry from the space, returning
null if there
currently is none. |
<T> T |
takeIfExistsById(Class<T> clazz,
Object id)
Take (remove) an object from the space matching its id and the class.
|
<T> T |
takeIfExistsById(Class<T> clazz,
Object id,
Object routing)
Take (remove) an object from the space matching its id, the class and the routing value.
|
<T> T |
takeIfExistsById(Class<T> clazz,
Object id,
Object routing,
long timeout)
Take (remove) an object from the space matching its id, the class and the routing value.
|
<T> T |
takeIfExistsById(Class<T> clazz,
Object id,
Object routing,
long timeout,
TakeModifiers modifiers)
Take (remove) an object from the space matching its id, the class and the routing value.
|
<T> T |
takeIfExistsById(IdQuery<T> query)
Take (remove) an object from the space matching the specified id query.
|
<T> T |
takeIfExistsById(IdQuery<T> query,
long timeout)
Take (remove) an object from the space matching the specified id query.
|
<T> T |
takeIfExistsById(IdQuery<T> query,
long timeout,
TakeModifiers modifiers)
Take (remove) an object from the space matching the specified id query.
|
<T> T[] |
takeMultiple(ISpaceQuery<T> template)
Takes (removes) all the entries matching the specified template from this space.
|
<T> T[] |
takeMultiple(ISpaceQuery<T> template,
int maxEntries)
Takes (removes) all the entries matching the specified template from this space.
|
<T> T[] |
takeMultiple(ISpaceQuery<T> template,
int maxEntries,
TakeModifiers modifiers)
Takes (removes) all the entries matching the specified template from this space.
|
<T> T[] |
takeMultiple(T template)
Takes (removes) all the entries matching the specified template from this space.
|
<T> T[] |
takeMultiple(T template,
int maxEntries)
Takes (removes) all the entries matching the specified template from this space.
|
<T> T[] |
takeMultiple(T template,
int maxEntries,
TakeModifiers modifiers)
Takes (removes) all the entries matching the specified template from this space.
|
String |
toString() |
<T> T |
wrap(String name,
Callable<T> c) |
<T> AsyncFuture<T> |
wrapFuture(AsyncFuture<T> future,
Transaction tx) |
<T> AsyncFutureListener<T> |
wrapListener(AsyncFutureListener<T> listener,
Transaction tx) |
<T> LeaseContext<T> |
write(T entry)
Writes a new object to the space, returning its
LeaseContext . |
<T> LeaseContext<T> |
write(T entry,
long lease)
Writes a new object to the space, returning its
LeaseContext . |
<T> LeaseContext<T> |
write(T entry,
long lease,
long timeout,
WriteModifiers modifiers)
Writes a new object to the space, returning its
LeaseContext . |
<T> LeaseContext<T> |
write(T entry,
WriteModifiers modifiers)
Writes a new object to the space, returning its
LeaseContext . |
<T> LeaseContext<T>[] |
writeMultiple(T[] entries)
Writes the specified entries to this space.
|
<T> LeaseContext<T>[] |
writeMultiple(T[] entries,
long lease)
Writes the specified entries to this space.
|
<T> LeaseContext<T>[] |
writeMultiple(T[] entries,
long[] leases,
long timeout,
WriteModifiers modifiers)
Writes the specified entries to this space.
|
<T> LeaseContext<T>[] |
writeMultiple(T[] entries,
long[] leases,
WriteModifiers modifiers)
Writes the specified entries to this space.
|
<T> LeaseContext<T>[] |
writeMultiple(T[] entries,
long lease,
long timeout,
WriteModifiers modifiers)
Writes the specified entries to this space.
|
<T> LeaseContext<T>[] |
writeMultiple(T[] entries,
long lease,
WriteModifiers modifiers)
Writes the specified entries to this space.
|
<T> LeaseContext<T>[] |
writeMultiple(T[] entries,
WriteModifiers modifiers)
Writes the specified entries to this space.
|
public DefaultGigaSpace(GigaSpaceConfigurer configurer)
configurer
- The transaction provider for declarative transaction ex.public void setName(String name)
public String getName()
GigaSpace
public String getSpaceName()
GigaSpace
getSpaceName
in interface GigaSpace
public boolean isSecured()
GigaSpace
public void setDefaultReadTimeout(long defaultReadTimeout)
read(Object)
or readIfExists(Object)
operations.public long getDefaultReadTimeout()
read(Object)
or readIfExists(Object)
operations.public void setDefaultTakeTimeout(long defaultTakeTimeout)
take(Object)
or takeIfExists(Object)
operations.public long getDefaultTakeTimeout()
take(Object)
or takeIfExists(Object)
operations.public void setDefaultWriteLease(long defaultWriteLease)
write(Object)
.public long getDefaultWriteLease()
write(Object)
.public int getDefaultIsolationLevel()
public void setDefaultWriteModifiers(WriteModifiers modifiers)
WriteModifiers
when excecution write(Object)
public void setDefaultClearModifiers(ClearModifiers modifiers)
ClearModifiers
when excecution write(Object)
public void setDefaultCountModifiers(CountModifiers modifiers)
CountModifiers
when excecution count(Object)
public void setDefaultReadModifiers(ReadModifiers modifiers)
ReadModifiers
when excecution read(Object)
public void setDefaultTakeModifiers(TakeModifiers modifiers)
TakeModifiers
when excecution take(Object)
public void setDefaultChangeModifiers(ChangeModifiers modifiers)
ChangeModifiers
when excecution change(Object, ChangeSet)
public WriteModifiers getDefaultWriteModifiers()
GigaSpace
WriteModifiers
set during this GigaSpace
configuration. This
value is configured either by using a GigaSpaceConfigurer
or through the pu.xml.getDefaultWriteModifiers
in interface GigaSpace
public ClearModifiers getDefaultClearModifiers()
GigaSpace
ClearModifiers
set during this GigaSpace
configuration. This
value is configured either by using a GigaSpaceConfigurer
or through the pu.xml.getDefaultClearModifiers
in interface GigaSpace
public CountModifiers getDefaultCountModifiers()
GigaSpace
CountModifiers
set during this GigaSpace
configuration. This
value is configured either by using a GigaSpaceConfigurer
or through the pu.xml. If
there is an active transaction and that transaction has any isolation level set on it, that
isolation level will be merged into the returned modifiers with any previously set isolation
level on the modifiers overriden.getDefaultCountModifiers
in interface GigaSpace
public ReadModifiers getDefaultReadModifiers()
GigaSpace
ReadModifiers
set during this GigaSpace
configuration. This
value is configured either by using a GigaSpaceConfigurer
or through the pu.xml. If
there is an active transaction and that transaction has any isolation level set on it, that
isolation level will be merged into the returned modifiers with any previously set isolation
level on the modifiers overriden.getDefaultReadModifiers
in interface GigaSpace
public TakeModifiers getDefaultTakeModifiers()
GigaSpace
TakeModifiers
set during this GigaSpace
configuration. This
value is configured either by using a GigaSpaceConfigurer
or through the pu.xml.getDefaultTakeModifiers
in interface GigaSpace
public ChangeModifiers getDefaultChangeModifiers()
GigaSpace
ChangeModifiers
set during this GigaSpace
configuration.
This value is configured either by using a GigaSpaceConfigurer
or through the
pu.xml.getDefaultChangeModifiers
in interface GigaSpace
public IJSpace getSpace()
GigaSpace
IJSpace
used by this GigaSpace implementation to delegate different
space operations. Allows the use of space operations that are not exposed by this interface, as well as use as a parameter to other low level GigaSpace components.
If
a transaction object is required for low level operations (as low level operations do not
have declarative transaction ex) the GigaSpace.getTxProvider()
should be used to acquire the
current running transaction.
public GigaSpace getClustered()
GigaSpace
GigaSpace
instance.
GigaSpace gigaSpace = new GigaSpaceConfigurer(space).clustered(true).gigaSpace();If this instance is already a clustered view (was initially constructed using the clustered flag), will return the same instance being used to issue the call. If this is a GigaSpace that works directly with a cluster member, will return a clustered view (as if it was constructed with the clustered flag set). Note that this method might return different instances when being called by different threads.
GigaSpace nonClusteredViewOfGigaSpace= ... // acquire non-clustered view of a clustered space GigaSpace space=nonClusteredViewofGigaSpace.getClustered(); // space != nonClusteredViewOfSpace
GigaSpace clusteredViewOfGigaSpace= ... // acquire clustered view of a clustered space GigaSpace space=clusteredViewofGigaSpace.getClustered(); // space == clusteredViewOfSpace
getClustered
in interface GigaSpace
GigaSpaceConfigurer.clustered(boolean)
public TransactionProvider getTxProvider()
GigaSpace
getTxProvider
in interface GigaSpace
public ExceptionTranslator getExceptionTranslator()
GigaSpace
getExceptionTranslator
in interface GigaSpace
public void clear(Object template) throws org.springframework.dao.DataAccessException
GigaSpace
If the clear operation conducted without transaction (null as value) it will clear all entries that are not under transaction. Therefore entries under transaction would not be removed from the space.
The clear operation supports inheritance, therefore
template class matching objects and its sub classes matching objects are part of the
candidates population to be removed from the space. You can in fact clean all space objects
(that are not under transaction) by calling: gigaSpace.clear(null)
.
Notice: The clear operation does not remove notify templates, i.e. registration for notifications.
public int clear(Object template, ClearModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
If the clear operation conducted without transaction (null as value) it will clear all entries that are not under transaction. Therefore entries under transaction would not be removed from the space.
The clear operation supports inheritance, therefore
template class matching objects and its sub classes matching objects are part of the
candidates population to be removed from the space. You can in fact remove all space objects
(that are not under transaction) by calling: gigaSpace.clear(null)
.
Notice: The clear operation does not remove notify templates i.e. registration for notifications.
clear
in interface GigaSpace
template
- the template to use for matchingmodifiers
- one or a union of ClearModifiers
.org.springframework.dao.DataAccessException
- In the event of an error, DataAccessException will wrap a
ClearException, accessible via DataAccessException.getRootCause().public int count(Object template) throws org.springframework.dao.DataAccessException
GigaSpace
count
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being wildcards ("match anything") other fields
being values ("match exactly on the serialized form").org.springframework.dao.DataAccessException
public int count(Object template, CountModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
Allows to specify modifiers using
ReadModifiers
which allows to programmatically control the isolation level this count
operation will be performed under.
count
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being wildcards ("match anything") other fields
being values ("match exactly on the serialized form").modifiers
- one or a union of CountModifiers
.org.springframework.dao.DataAccessException
public <T> ISpaceQuery<T> snapshot(Object entry) throws org.springframework.dao.DataAccessException
GigaSpace
The process of serializing an entry for transmission to a JavaSpaces service will be identical if the same entry is used twice. This is most likely to be an issue with templates that are used repeatedly to search for entries with read or take.
The client-side implementations of read and take cannot reasonably avoid this duplicated effort, since they have no efficient way of checking whether the same template is being used without intervening modification.
The snapshot method gives the JavaSpaces service implementor a way to reduce the impact of repeated use of the same entry. Invoking snapshot with an Entry will return another Entry object that contains a snapshot of the original entry. Using the returned snapshot entry is equivalent to using the unmodified original entry in all operations on the same JavaSpaces service.
Modifications to the original entry will
not affect the snapshot. You can snapshot a null template; snapshot may or may not return
null given a null template. The entry returned from snapshot will be guaranteed equivalent to
the original unmodified object only when used with the space. Using the snapshot with any
other JavaSpaces service will generate an IllegalArgumentException
unless the
other space can use it because of knowledge about the JavaSpaces service that generated the
snapshot.
The snapshot will be a different object from the original, may or may not
have the same hash code, and equals may or may not return true when invoked with the original
object, even if the original object is unmodified. A snapshot is guaranteed to work only
within the virtual machine in which it was generated. If a snapshot is passed to another
virtual machine (for example, in a parameter of an RMI call), using it--even with the same
JavaSpaces service--may generate an IllegalArgumentException
.
public <T> T readById(Class<T> clazz, Object id)
GigaSpace
null
if
there is no match. The timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
Note, if the space is partitioned, and
the Entry has a specific property for its routing value, the operation will broadcast to all
partitions. The GigaSpace.readById(Class, Object, Object)
can be used to specify the routing.
public <T> T readById(Class<T> clazz, Object id, Object routing)
GigaSpace
null
if there is no match. The timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
public <T> T readById(Class<T> clazz, Object id, Object routing, long timeout)
GigaSpace
null
if there is no match within the specified timeout.readById
in interface GigaSpace
clazz
- The class of the entryid
- The id of the entryrouting
- The routing valuetimeout
- The timeout value to wait for a matching entry if it does not exists within
the spacenull
if no matching is found within the timeout
value.public <T> T readById(Class<T> clazz, Object id, Object routing, long timeout, ReadModifiers modifiers)
GigaSpace
null
if there is no match within the specified timeout.readById
in interface GigaSpace
clazz
- The class of the entryid
- The id of the entryrouting
- The routing valuetimeout
- The timeout value to wait for a matching entry if it does not exists within
the spacemodifiers
- one or a union of ReadModifiers
.null
if no matching is found within the timeout
value.public <T> T readById(IdQuery<T> query) throws org.springframework.dao.DataAccessException
GigaSpace
null
if
there is no match. The timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
Note, if the space is partitioned, and
the Entry has a specific property for its routing value, the operation will broadcast to all
partitions. The GigaSpace.readById(Class, Object, Object)
can be used to specify the routing.
public <T> T readById(IdQuery<T> query, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
if
there is no match within the specified timeout.readById
in interface GigaSpace
query
- Query to search by.timeout
- The timeout value to wait for a matching entry if it does not exists within
the spacenull
if no matching is found within the timeout
value.org.springframework.dao.DataAccessException
public <T> T readById(IdQuery<T> query, long timeout, ReadModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
if
there is no match within the specified timeout.readById
in interface GigaSpace
query
- Query to search by.timeout
- The timeout value to wait for a matching entry if it does not exists within
the spacemodifiers
- one or a union of ReadModifiers
.null
if no matching is found within the timeout
value.org.springframework.dao.DataAccessException
public <T> T read(T template) throws org.springframework.dao.DataAccessException
GigaSpace
null
if the timeout expires. Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
read
in interface GigaSpace
template
- The template used for matching. Matching is done against template with
null
fields being wildcards ("match anything") other fields
being values ("match exactly on the serialized form").org.springframework.dao.DataAccessException
public <T> T read(T template, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
if the timeout expires.read
in interface GigaSpace
template
- The template used for matching. Matching is done against template with
null
fields being wildcards ("match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.org.springframework.dao.DataAccessException
public <T> T read(T template, long timeout, ReadModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
if the timeout expires. Overloads GigaSpace.read(Object, long)
by adding a
modifiers
parameter. Equivalent when called with the default modifier - ReadModifiers.REPEATABLE_READ
. Modifiers are used to define the behavior of a read
operation.
read
in interface GigaSpace
template
- The template used for matching. Matching is done against template with
null
fields being wildcards ("match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.modifiers
- one or a union of ReadModifiers
.org.springframework.dao.DataAccessException
public <T> T read(ISpaceQuery<T> template) throws org.springframework.dao.DataAccessException
GigaSpace
null
if the timeout expires. Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
public <T> T read(ISpaceQuery<T> template, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
if the timeout expires.read
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.org.springframework.dao.DataAccessException
public <T> T read(ISpaceQuery<T> template, long timeout, ReadModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
if the timeout expires. Overloads GigaSpace.read(Object, long)
by adding a
modifiers
parameter. Equivalent when called with the default modifier - ReadModifiers.REPEATABLE_READ
. Modifiers are used to define the behavior of a read
operation.
read
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.modifiers
- one or a union of ReadModifiers
.org.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncRead(T template) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case
there was no match). Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
asyncRead
in interface GigaSpace
template
- The template used for matching. Matching is done against template with
null
fields being wildcards ("match anything") other fields
being values ("match exactly on the serialized form").org.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncRead(T template, AsyncFutureListener<T> listener) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case
there was no match). Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
asyncRead
in interface GigaSpace
template
- The template used for matching. Matching is done against template with
null
fields being wildcards ("match anything") other fields
being values ("match exactly on the serialized form").listener
- A listener to be notified when a result arrivesorg.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncRead(T template, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case
there was no match).asyncRead
in interface GigaSpace
template
- The template used for matching. Matching is done against template with
null
fields being wildcards ("match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.org.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncRead(T template, long timeout, AsyncFutureListener<T> listener) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case
there was no match).asyncRead
in interface GigaSpace
template
- The template used for matching. Matching is done against template with
null
fields being wildcards ("match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.listener
- A listener to be notified when a result arrivesorg.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncRead(T template, long timeout, ReadModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case
there was no match). Overloads GigaSpace.asyncRead(Object, long)
by adding a
modifiers
parameter. Equivalent when called with the default modifier - ReadModifiers.REPEATABLE_READ
. Modifiers are used to define the behavior of a read
operation.
asyncRead
in interface GigaSpace
template
- The template used for matching. Matching is done against template with
null
fields being wildcards ("match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.modifiers
- one or a union of ReadModifiers
.org.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncRead(T template, long timeout, ReadModifiers modifiers, AsyncFutureListener<T> listener) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case
there was no match). Overloads GigaSpace.asyncRead(Object, long)
by adding a
modifiers
parameter. Equivalent when called with the default modifier - ReadModifiers.REPEATABLE_READ
. Modifiers are used to define the behavior of a read
operation.
asyncRead
in interface GigaSpace
template
- The template used for matching. Matching is done against template with
null
fields being wildcards ("match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.modifiers
- one or a union of ReadModifiers
.listener
- A listener to be notified when a result arrivesorg.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncRead(ISpaceQuery<T> template) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case
there was no match). Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
public <T> AsyncFuture<T> asyncRead(ISpaceQuery<T> template, AsyncFutureListener<T> listener) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case
there was no match). Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
asyncRead
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.listener
- A listener to be notified when a result arrivesorg.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncRead(ISpaceQuery<T> template, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case
there was no match).asyncRead
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.org.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncRead(ISpaceQuery<T> template, long timeout, AsyncFutureListener<T> listener) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case
there was no match).asyncRead
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.listener
- A listener to be notified when a result arrivesorg.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncRead(ISpaceQuery<T> template, long timeout, ReadModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case
there was no match). Overloads GigaSpace.asyncRead(Object, long)
by adding a
modifiers
parameter. Equivalent when called with the default modifier - ReadModifiers.REPEATABLE_READ
. Modifiers are used to define the behavior of a read
operation.
asyncRead
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.modifiers
- one or a union of ReadModifiers
.org.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncRead(ISpaceQuery<T> template, long timeout, ReadModifiers modifiers, AsyncFutureListener<T> listener) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case
there was no match). Overloads GigaSpace.asyncRead(Object, long)
by adding a
modifiers
parameter. Equivalent when called with the default modifier - ReadModifiers.REPEATABLE_READ
. Modifiers are used to define the behavior of a read
operation.
asyncRead
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.modifiers
- one or a union of ReadModifiers
.listener
- A listener to be notified when a result arrivesorg.springframework.dao.DataAccessException
public <T> T readIfExistsById(Class<T> clazz, Object id)
GigaSpace
null
if
there is no match. Matching and timeouts are done as in readById
, except
that blocking in this call is done only if necessary to wait for transactional state to
settle.
The timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
Note, if the space is partitioned, and the Entry has
a specific property for its routing value, the operation will broadcast to all partitions.
The GigaSpace.readById(Class, Object, Object)
can be used to specify the routing.
readIfExistsById
in interface GigaSpace
clazz
- The class of the entryid
- The id of the entrynull
if no matching is found within the timeout
value.public <T> T readIfExistsById(Class<T> clazz, Object id, Object routing)
GigaSpace
null
if there is no match. Matching and timeouts are done as in
readById
, except that blocking in this call is done only if necessary to wait
for transactional state to settle.
The timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
readIfExistsById
in interface GigaSpace
clazz
- The class of the entryid
- The id of the entryrouting
- The routing valuenull
if no matching is found within the timeout
value.public <T> T readIfExistsById(Class<T> clazz, Object id, Object routing, long timeout)
GigaSpace
null
if there is no match within the specified timeout. Matching and
timeouts are done as in readById
, except that blocking in this call is done only
if necessary to wait for transactional state to settle.
readIfExistsById
in interface GigaSpace
clazz
- The class of the entryid
- The id of the entryrouting
- The routing valuetimeout
- The timeout value to wait for a matching entry if it does not exists within
the spacenull
if no matching is found within the timeout
value.public <T> T readIfExistsById(Class<T> clazz, Object id, Object routing, long timeout, ReadModifiers modifiers)
GigaSpace
null
if there is no match within the specified timeout. Matching and
timeouts are done as in readById
, except that blocking in this call is done only
if necessary to wait for transactional state to settle.
readIfExistsById
in interface GigaSpace
clazz
- The class of the entryid
- The id of the entryrouting
- The routing valuetimeout
- The timeout value to wait for a matching entry if it does not exists within
the spacemodifiers
- one or a union of ReadModifiers
.null
if no matching is found within the timeout
value.public <T> T readIfExistsById(IdQuery<T> query) throws org.springframework.dao.DataAccessException
GigaSpace
null
if
there is no match. The timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
Note, if the space is partitioned, and
the Entry has a specific property for its routing value, the operation will broadcast to all
partitions. The GigaSpace.readById(Class, Object, Object)
can be used to specify the routing.
Matching and timeouts are done as in readById
, except that blocking in
this call is done only if necessary to wait for transactional state to settle.
readIfExistsById
in interface GigaSpace
query
- Query to search by.null
if no matching is found within the timeout
value.org.springframework.dao.DataAccessException
public <T> T readIfExistsById(IdQuery<T> query, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
if
there is no match within the specified timeout. Matching and timeouts are done as in
readById
, except that blocking in this call is done only if necessary to wait
for transactional state to settle.
readIfExistsById
in interface GigaSpace
query
- Query to search by.timeout
- The timeout value to wait for a matching entry if it does not exists within
the spacenull
if no matching is found within the timeout
value.org.springframework.dao.DataAccessException
public <T> T readIfExistsById(IdQuery<T> query, long timeout, ReadModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
if
there is no match within the specified timeout. Matching and timeouts are done as in
readById
, except that blocking in this call is done only if necessary to wait
for transactional state to settle.
readIfExistsById
in interface GigaSpace
query
- Query to search by.timeout
- The timeout value to wait for a matching entry if it does not exists within
the spacemodifiers
- one or a union of ReadModifiers
.null
if no matching is found within the timeout
value.org.springframework.dao.DataAccessException
public <T> T readIfExists(T template) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there currently is
none. Matching and timeouts are done as in read
, except that blocking in this
call is done only if necessary to wait for transactional state to settle. Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
readIfExists
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being wildcards ("match anything") other fields
being values ("match exactly on the serialized form").org.springframework.dao.DataAccessException
public <T> T readIfExists(T template, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there currently is
none. Matching and timeouts are done as in read
, except that blocking in this
call is done only if necessary to wait for transactional state to settle.readIfExists
in interface GigaSpace
template
- The template used for matching. Matching is done against template with
null
fields being wildcards ("match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.org.springframework.dao.DataAccessException
public <T> T readIfExists(T template, long timeout, ReadModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there currently is
none. Matching and timeouts are done as in read
, except that blocking in this
call is done only if necessary to wait for transactional state to settle. Overloads
GigaSpace.read(Object, long)
by adding a modifiers
parameter. Equivalent when
called with the default modifier - ReadModifiers.REPEATABLE_READ
. Modifiers are used
to define the behavior of a read operation.
readIfExists
in interface GigaSpace
template
- The template used for matching. Matching is done against template with
null
fields being wildcards ("match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.modifiers
- one or a union of ReadModifiers
.org.springframework.dao.DataAccessException
public <T> T readIfExists(ISpaceQuery<T> template) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there currently is
none. Matching and timeouts are done as in read
, except that blocking in this
call is done only if necessary to wait for transactional state to settle. Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
readIfExists
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.org.springframework.dao.DataAccessException
public <T> T readIfExists(ISpaceQuery<T> template, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there currently is
none. Matching and timeouts are done as in read
, except that blocking in this
call is done only if necessary to wait for transactional state to settle.readIfExists
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.org.springframework.dao.DataAccessException
public <T> T readIfExists(ISpaceQuery<T> template, long timeout, ReadModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there currently is
none. Matching and timeouts are done as in read
, except that blocking in this
call is done only if necessary to wait for transactional state to settle. Overloads
GigaSpace.read(Object, long)
by adding a modifiers
parameter. Equivalent when
called with the default modifier - ReadModifiers.REPEATABLE_READ
. Modifiers are used
to define the behavior of a read operation.
readIfExists
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
object. A timeout of 0 means to wait no time at all.modifiers
- one or a union of ReadModifiers
.org.springframework.dao.DataAccessException
public <T> T[] readMultiple(T template) throws org.springframework.dao.DataAccessException
GigaSpace
read
without
timeout (0). Returns an unbounded array of matches. Returns an empty array if no match was
found. Same as calling readMultiple(template,
Integer.MAX_VALUE)
.readMultiple
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classesorg.springframework.dao.DataAccessException
- In the event of a read error, DataAccessException will wrap a
ReadMultipleException, accessible via DataAccessException.getRootCause().public <T> T[] readMultiple(T template, int maxEntries) throws org.springframework.dao.DataAccessException
GigaSpace
read
without
timeout (0). Returns an array with matches bound by maxEntries
. Returns an empty
array if no match was found.readMultiple
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can
also be one of the different ISpaceQuery
classesmaxEntries
- A limit on the number of entries to be returned. Use Integer.MAX_VALUE
for the uppermost limit.org.springframework.dao.DataAccessException
- In the event of a read error, DataAccessException will wrap a
ReadMultipleException, accessible via DataAccessException.getRootCause().public <T> T[] readMultiple(T template, int maxEntries, ReadModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
read
without
timeout (0). Returns an array with matches bound by maxEntries
. Returns an empty
array if no match was found. Overloads GigaSpace.readMultiple(Object, int)
by adding a
modifiers
parameter. Equivalent when called with the default modifier - ReadModifiers.REPEATABLE_READ
. Modifiers are used to define the behavior of a read
operation.
readMultiple
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can
also be one of the different ISpaceQuery
classesmaxEntries
- A limit on the number of entries to be returned. Use Integer.MAX_VALUE
for the uppermost limit.modifiers
- one or a union of ReadModifiers
.org.springframework.dao.DataAccessException
- In the event of a read error, DataAccessException will wrap a
ReadMultipleException, accessible via DataAccessException.getRootCause().public <T> T[] readMultiple(ISpaceQuery<T> template) throws org.springframework.dao.DataAccessException
GigaSpace
read
without
timeout (0). Returns an unbounded array of matches. Returns an empty array if no match was
found.readMultiple
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.org.springframework.dao.DataAccessException
- In the event of a read error, DataAccessException will wrap a
ReadMultipleException, accessible via DataAccessException.getRootCause().public <T> T[] readMultiple(ISpaceQuery<T> template, int maxEntries) throws org.springframework.dao.DataAccessException
GigaSpace
read
without
timeout (0). Returns an array with matches bound by maxEntries
. Returns an empty
array if no match was found.readMultiple
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.maxEntries
- A limit on the number of entries to be returned. Use Integer.MAX_VALUE
for the uppermost limit.org.springframework.dao.DataAccessException
- In the event of a read error, DataAccessException will wrap a
ReadMultipleException, accessible via DataAccessException.getRootCause().public <T> T[] readMultiple(ISpaceQuery<T> template, int maxEntries, ReadModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
read
without
timeout (0). Returns an array with matches bound by maxEntries
. Returns an empty
array if no match was found. Overloads GigaSpace.readMultiple(Object, int)
by adding a
modifiers
parameter. Equivalent when called with the default modifier - ReadModifiers.REPEATABLE_READ
. Modifiers are used to define the behavior of a read
operation.
readMultiple
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.maxEntries
- A limit on the number of entries to be returned. Use Integer.MAX_VALUE
for the uppermost limit.modifiers
- one or a union of ReadModifiers
.org.springframework.dao.DataAccessException
- In the event of a read error, DataAccessException will wrap a
ReadMultipleException, accessible via DataAccessException.getRootCause().public <T> T takeById(Class<T> clazz, Object id)
GigaSpace
null
if there is no match. The timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
Note, if the
space is partitioned, and the Entry has a specific property for its routing value, the
operation will broadcast to all partitions. The GigaSpace.takeById(Class, Object, Object)
can
be used to specify the routing.
public <T> T takeById(Class<T> clazz, Object id, Object routing)
GigaSpace
null
if there is no match. The timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
public <T> T takeById(Class<T> clazz, Object id, Object routing, long timeout)
GigaSpace
null
if there is no match within the specified timeout.takeById
in interface GigaSpace
clazz
- The class of the entryid
- The id of the entryrouting
- The routing valuetimeout
- The timeout value to wait for a matching entry if it does not exists within
the spacenull
if no matching is found within the timeout
value.public <T> T takeById(Class<T> clazz, Object id, Object routing, long timeout, TakeModifiers modifiers)
GigaSpace
null
if there is no match within the specified timeout.takeById
in interface GigaSpace
clazz
- The class of the entryid
- The id of the entryrouting
- The routing valuetimeout
- The timeout value to wait for a matching entry if it does not exists within
the spacemodifiers
- one or a union of TakeModifiers
.null
if no matching is found within the timeout
value.public <T> T takeById(IdQuery<T> query) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there is no match. The timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
Note, if the
space is partitioned, and the Entry has a specific property for its routing value, the
operation will broadcast to all partitions. The GigaSpace.readById(Class, Object, Object)
can
be used to specify the routing.
public <T> T takeById(IdQuery<T> query, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there is no match within the specified timeout.takeById
in interface GigaSpace
query
- Query to search by.timeout
- The timeout value to wait for a matching entry if it does not exists within
the spacenull
if no matching is found within the timeout
value.org.springframework.dao.DataAccessException
public <T> T takeById(IdQuery<T> query, long timeout, TakeModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there is no match within the specified timeout.takeById
in interface GigaSpace
query
- Query to search by.timeout
- The timeout value to wait for a matching entry if it does not exists within
the spacemodifiers
- one or a union of TakeModifiers
.null
if no matching is found within the timeout
value.org.springframework.dao.DataAccessException
public <T> T take(T template) throws org.springframework.dao.DataAccessException
GigaSpace
null
if the timeout expires. Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
take
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being wildcards ( "match anything") other fields
being values ("match exactly on the serialized form").org.springframework.dao.DataAccessException
public <T> T take(T template, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
if the timeout expires.take
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being wildcards ( "match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.org.springframework.dao.DataAccessException
public <T> T take(T template, long timeout, TakeModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
if the timeout expires.take
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being wildcards ( "match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.modifiers
- one or a union of TakeModifiers
.org.springframework.dao.DataAccessException
public <T> T take(ISpaceQuery<T> template) throws org.springframework.dao.DataAccessException
GigaSpace
null
if the timeout expires. Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
public <T> T take(ISpaceQuery<T> template, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
if the timeout expires.take
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.org.springframework.dao.DataAccessException
public <T> T take(ISpaceQuery<T> template, long timeout, TakeModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
if the timeout expires.take
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.modifiers
- one or a union of TakeModifiers
.org.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncTake(T template) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case there was no match). Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
asyncTake
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being wildcards ( "match anything") other fields
being values ("match exactly on the serialized form").org.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncTake(T template, AsyncFutureListener<T> listener) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case there was no match). Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
asyncTake
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being wildcards ( "match anything") other fields
being values ("match exactly on the serialized form").listener
- A listener to be notified when a result arrivesorg.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncTake(T template, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case there was no match).asyncTake
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being wildcards ( "match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.org.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncTake(T template, long timeout, AsyncFutureListener<T> listener) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case there was no match).asyncTake
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being wildcards ( "match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.listener
- A listener to be notified when a result arrivesorg.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncTake(T template, long timeout, TakeModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case there was no match).asyncTake
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being wildcards ( "match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.modifiers
- one or a union of TakeModifiers
.org.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncTake(T template, long timeout, TakeModifiers modifiers, AsyncFutureListener<T> listener) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case there was no match).asyncTake
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being wildcards ( "match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.modifiers
- one or a union of TakeModifiers
.listener
- A listener to be notified when a result arrivesorg.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncTake(ISpaceQuery<T> template) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case there was no match). Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
public <T> AsyncFuture<T> asyncTake(ISpaceQuery<T> template, AsyncFutureListener<T> listener) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case there was no match). Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
public <T> AsyncFuture<T> asyncTake(ISpaceQuery<T> template, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case there was no match).asyncTake
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.org.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncTake(ISpaceQuery<T> template, long timeout, AsyncFutureListener<T> listener) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case there was no match).asyncTake
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.listener
- A listener to be notified when a result arrives.org.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncTake(ISpaceQuery<T> template, long timeout, TakeModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case there was no match).asyncTake
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.modifiers
- one or a union of TakeModifiers
.org.springframework.dao.DataAccessException
public <T> AsyncFuture<T> asyncTake(ISpaceQuery<T> template, long timeout, TakeModifiers modifiers, AsyncFutureListener<T> listener) throws org.springframework.dao.DataAccessException
GigaSpace
null
in case there was no match).asyncTake
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.modifiers
- one or a union of TakeModifiers
.listener
- A listener to be notified when a result arrives.org.springframework.dao.DataAccessException
public <T> T takeIfExistsById(Class<T> clazz, Object id)
GigaSpace
null
if there is no match. Matching and timeouts are done as in
takeById
, except that blocking in this call is done only if necessary to wait
for transactional state to settle.
The timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
Note, if the space is
partitioned, and the Entry has a specific property for its routing value, the operation will
broadcast to all partitions. The GigaSpace.takeById(Class, Object, Object)
can be used to
specify the routing.
takeIfExistsById
in interface GigaSpace
clazz
- The class of the entryid
- The id of the entrynull
if no matching is found within the timeout
value.public <T> T takeIfExistsById(Class<T> clazz, Object id, Object routing)
GigaSpace
null
if there is no match. Matching and timeouts are done as in
takeById
, except that blocking in this call is done only if necessary to wait
for transactional state to settle.
The timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
takeIfExistsById
in interface GigaSpace
clazz
- The class of the entryid
- The id of the entryrouting
- The routing valuenull
if no matching is found within the timeout
value.public <T> T takeIfExistsById(Class<T> clazz, Object id, Object routing, long timeout)
GigaSpace
null
if there is no match within the specified timeout. Matching
and timeouts are done as in takeById
, except that blocking in this call is done
only if necessary to wait for transactional state to settle.
takeIfExistsById
in interface GigaSpace
clazz
- The class of the entryid
- The id of the entryrouting
- The routing valuetimeout
- The timeout value to wait for a matching entry if it does not exists within
the spacenull
if no matching is found within the timeout
value.public <T> T takeIfExistsById(Class<T> clazz, Object id, Object routing, long timeout, TakeModifiers modifiers)
GigaSpace
null
if there is no match within the specified timeout. Matching
and timeouts are done as in takeById
, except that blocking in this call is done
only if necessary to wait for transactional state to settle.
takeIfExistsById
in interface GigaSpace
clazz
- The class of the entryid
- The id of the entryrouting
- The routing valuetimeout
- The timeout value to wait for a matching entry if it does not exists within
the spacemodifiers
- one or a union of TakeModifiers
.null
if no matching is found within the timeout
value.public <T> T takeIfExistsById(IdQuery<T> query) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there is no match. The timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
Note, if the
space is partitioned, and the Entry has a specific property for its routing value, the
operation will broadcast to all partitions. The GigaSpace.readById(Class, Object, Object)
can
be used to specify the routing.
Matching and timeouts are done as in
readById
, except that blocking in this call is done only if necessary to wait
for transactional state to settle.
takeIfExistsById
in interface GigaSpace
query
- Query to search by.null
if no matching is found within the timeout
value.org.springframework.dao.DataAccessException
public <T> T takeIfExistsById(IdQuery<T> query, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there is no match within the specified timeout. Matching and
timeouts are done as in readById
, except that blocking in this call is done only
if necessary to wait for transactional state to settle.
takeIfExistsById
in interface GigaSpace
query
- Query to search by.timeout
- The timeout value to wait for a matching entry if it does not exists within
the spacenull
if no matching is found within the timeout
value.org.springframework.dao.DataAccessException
public <T> T takeIfExistsById(IdQuery<T> query, long timeout, TakeModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there is no match within the specified timeout. Matching and
timeouts are done as in readById
, except that blocking in this call is done only
if necessary to wait for transactional state to settle.
takeIfExistsById
in interface GigaSpace
query
- Query to search by.timeout
- The timeout value to wait for a matching entry if it does not exists within
the spacemodifiers
- one or a union of TakeModifiers
.null
if no matching is found within the timeout
value.org.springframework.dao.DataAccessException
public <T> T takeIfExists(T template) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there
currently is none. Matching and timeouts are done as in take
, except that
blocking in this call is done only if necessary to wait for transactional state to settle.
Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
takeIfExists
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being wildcards ( "match anything") other fields
being values ("match exactly on the serialized form").org.springframework.dao.DataAccessException
public <T> T takeIfExists(T template, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there
currently is none. Matching and timeouts are done as in take
, except that
blocking in this call is done only if necessary to wait for transactional state to settle.takeIfExists
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being wildcards ( "match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.org.springframework.dao.DataAccessException
public <T> T takeIfExists(T template, long timeout, TakeModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there
currently is none. Matching and timeouts are done as in take
, except that
blocking in this call is done only if necessary to wait for transactional state to settle.takeIfExists
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being wildcards ( "match anything") other fields
being values ("match exactly on the serialized form").timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.modifiers
- one or a union of TakeModifiers
.org.springframework.dao.DataAccessException
public <T> T takeIfExists(ISpaceQuery<T> template) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there
currently is none. Matching and timeouts are done as in take
, except that
blocking in this call is done only if necessary to wait for transactional state to settle.
Note, the timeout is the default timeout this interface is configured with (using its factory) and defaults to 0.
takeIfExists
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.org.springframework.dao.DataAccessException
public <T> T takeIfExists(ISpaceQuery<T> template, long timeout) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there
currently is none. Matching and timeouts are done as in take
, except that
blocking in this call is done only if necessary to wait for transactional state to settle.takeIfExists
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.org.springframework.dao.DataAccessException
public <T> T takeIfExists(ISpaceQuery<T> template, long timeout, TakeModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
null
if there
currently is none. Matching and timeouts are done as in take
, except that
blocking in this call is done only if necessary to wait for transactional state to settle.takeIfExists
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.timeout
- How long the client is willing to wait for a transactionally proper matching
entry. A timeout of 0 means to wait no time at all.modifiers
- one or a union of TakeModifiers
.org.springframework.dao.DataAccessException
public <T> T[] takeMultiple(T template) throws org.springframework.dao.DataAccessException
GigaSpace
takeMultiple(template, Integer.MAX_VALUE)
.takeMultiple
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classesorg.springframework.dao.DataAccessException
- In the event of a take error, DataAccessException will wrap a
TakeMultipleException, accessible via DataAccessException.getRootCause().public <T> T[] takeMultiple(T template, int maxEntries) throws org.springframework.dao.DataAccessException
GigaSpace
takeMultiple
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can
also be one of the different ISpaceQuery
classesmaxEntries
- A limit on the number of entries to be returned. Use Integer.MAX_VALUE
for the uppermost limit.org.springframework.dao.DataAccessException
- In the event of a take error, DataAccessException will wrap a
TakeMultipleException, accessible via DataAccessException.getRootCause().public <T> T[] takeMultiple(ISpaceQuery<T> template) throws org.springframework.dao.DataAccessException
GigaSpace
takeMultiple
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.org.springframework.dao.DataAccessException
- In the event of a take error, DataAccessException will wrap a
TakeMultipleException, accessible via DataAccessException.getRootCause().public <T> T[] takeMultiple(ISpaceQuery<T> template, int maxEntries) throws org.springframework.dao.DataAccessException
GigaSpace
takeMultiple
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.maxEntries
- A limit on the number of entries to be returned. Use Integer.MAX_VALUE
for the uppermost limit.org.springframework.dao.DataAccessException
- In the event of a take error, DataAccessException will wrap a
TakeMultipleException, accessible via DataAccessException.getRootCause().public <T> T[] takeMultiple(T template, int maxEntries, TakeModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
takeMultiple
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can
also be one of the different ISpaceQuery
classesmaxEntries
- A limit on the number of entries to be returned. Use Integer.MAX_VALUE
for the uppermost limit.modifiers
- one or a union of TakeModifiers
.org.springframework.dao.DataAccessException
- In the event of a take error, DataAccessException will wrap a
TakeMultipleException, accessible via DataAccessException.getRootCause().public <T> T[] takeMultiple(ISpaceQuery<T> template, int maxEntries, TakeModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
takeMultiple
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.maxEntries
- A limit on the number of entries to be returned. Use Integer.MAX_VALUE
for the uppermost limit.modifiers
- one or a union of TakeModifiers
.org.springframework.dao.DataAccessException
- In the event of a take error, DataAccessException will wrap a
TakeMultipleException, accessible via DataAccessException.getRootCause().public <T> LeaseContext<T> write(T entry) throws org.springframework.dao.DataAccessException
GigaSpace
LeaseContext
.
By default uses the WriteModifiers.UPDATE_OR_WRITE
modifier (see GigaSpace.write(Object, long, long, WriteModifiers)
. In order to force the operation to perform "write" only (a
bit more performant), the WriteModifiers.WRITE_ONLY
modifier can be used resulting in
an EntryAlreadyInSpaceException
if the entry already exists in
the space (it must have an id for this exception to be raised).
If the object has a
primary key that isn't auto - generated, and the modifiers value is one of WriteModifiers.UPDATE_OR_WRITE
, WriteModifiers.UPDATE_ONLY
or WriteModifiers.PARTIAL_UPDATE
, it will call to the update method, returning a LeaseContext
holder. This lease is unknown to the grantor, unless an actual 'write' was performed.
The entry will be written using the default lease this interface is configured with (using
the its factory). In order to explicitly define the lease, please use GigaSpace.write(Object,
long)
.
write
in interface GigaSpace
entry
- The entry to write to the spaceLease
on a successful write, or null
if performed
with the proxy configured with NoWriteLease flag. when WriteModifiers.UPDATE_OR_WRITE
modifier is applied, LeaseContext.getObject()
returns
null
on a successful write or the previous value - on successful update (Only if
WriteModifiers.RETURN_PREV_ON_UPDATE
is used, otherwise null). UpdateOperationTimeoutException
is thrown if timeout occurred while
trying to update the object.
org.springframework.dao.DataAccessException
public <T> LeaseContext<T> write(T entry, long lease) throws org.springframework.dao.DataAccessException
GigaSpace
LeaseContext
.
By default uses the WriteModifiers.UPDATE_OR_WRITE
modifier (see GigaSpace.write(Object, long, long, WriteModifiers)
. In order to force the operation to perform "write" only (a
bit more performant), the WriteModifiers.WRITE_ONLY
modifier can be used resulting in
an EntryAlreadyInSpaceException
if the entry already exists in
the space (it must have an id for this exception to be raised).
If the object has a
primary key that isn't auto - generated, and the modifiers value is one of WriteModifiers.UPDATE_OR_WRITE
, WriteModifiers.UPDATE_ONLY
or WriteModifiers.PARTIAL_UPDATE
, it will call to the update method, returning a LeaseContext
holder. This lease is unknown to the grantor, unless an actual 'write' was performed.
write
in interface GigaSpace
entry
- The entry to write to the spacelease
- The lease the entry will be written with, in milliseconds.Lease
on a successful write, or null
if performed
with the proxy configured with NoWriteLease flag. when WriteModifiers.UPDATE_OR_WRITE
modifier is applied, LeaseContext.getObject()
returns
null
on a successful write or the previous value - on successful update (Only if
WriteModifiers.RETURN_PREV_ON_UPDATE
is used, otherwise null). UpdateOperationTimeoutException
is thrown if timeout occurred while
trying to update the object.
org.springframework.dao.DataAccessException
public <T> LeaseContext<T> write(T entry, WriteModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
LeaseContext
.
By default uses the WriteModifiers.UPDATE_OR_WRITE
modifier (see GigaSpace.write(Object, long, long, WriteModifiers)
. In order to force the operation to perform "write" only (a
bit more performant), the WriteModifiers.WRITE_ONLY
modifier can be used resulting in
an EntryAlreadyInSpaceException
if the entry already exists in
the space (it must have an id for this exception to be raised).
If the object has a
primary key that isn't auto - generated, and the modifiers value is one of WriteModifiers.UPDATE_OR_WRITE
, WriteModifiers.UPDATE_ONLY
or WriteModifiers.PARTIAL_UPDATE
, it will call to the update method, returning a LeaseContext
holder. This lease is unknown to the grantor, unless an actual 'write' was performed.
The entry will be written using the default lease this interface is configured with (using
the its factory). In order to explicitly define the lease, please use GigaSpace.write(Object,
long)
.
write
in interface GigaSpace
entry
- The entry to write to the spacemodifiers
- one or a union of WriteModifiers
.Lease
on a successful write, or null
if performed
with the proxy configured with NoWriteLease flag. when WriteModifiers.UPDATE_OR_WRITE
modifier is applied, LeaseContext.getObject()
returns
null
on a successful write or the previous value - on successful update (Only if
WriteModifiers.RETURN_PREV_ON_UPDATE
is used, otherwise null). UpdateOperationTimeoutException
is thrown if timeout occurred while
trying to update the object.
org.springframework.dao.DataAccessException
public <T> LeaseContext<T> write(T entry, long lease, long timeout, WriteModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
LeaseContext
.
By default uses the WriteModifiers.UPDATE_OR_WRITE
modifier.
In order to force the operation to perform "write" only (a bit more performant), the WriteModifiers.WRITE_ONLY
modifier can be used resulting in an EntryAlreadyInSpaceException
if the entry already exists in the space
(it must have an id for this exception to be raised).
If the object has a primary key
that isn't auto - generated, and the modifiers value is one of WriteModifiers.UPDATE_OR_WRITE
, WriteModifiers.UPDATE_ONLY
or WriteModifiers.PARTIAL_UPDATE
, it will call to the update method, returning a LeaseContext
holder. This lease is unknown to the grantor, unless an actual 'write' was performed.
write
in interface GigaSpace
entry
- The entry to write to the spacelease
- The lease the entry will be written with, in milliseconds.timeout
- The timeout of an update operation, in milliseconds. If the entry is
locked by another transaction wait for the specified number of milliseconds
for it to be released.modifiers
- one or a union of WriteModifiers
.Lease
on a successful write, or null
if performed
with the proxy configured with NoWriteLease flag. when WriteModifiers.UPDATE_OR_WRITE
modifier is applied, LeaseContext.getObject()
returns
null
on a successful write or the previous value - on successful update (Only if
WriteModifiers.RETURN_PREV_ON_UPDATE
is used, otherwise null). UpdateOperationTimeoutException
is thrown if timeout occurred while
trying to update the object.
org.springframework.dao.DataAccessException
public <T> AggregationResult aggregate(ISpaceQuery<T> query, AggregationSet aggregationSet)
GigaSpace
aggregate
in interface GigaSpace
query
- Query to search byaggregationSet
- aggregations to executeQueryExtension
public <T> AggregationResult aggregate(ISpaceQuery<T> query, AggregationSet aggregationSet, ReadModifiers readModifiers)
public <T> ChangeResult<T> change(ISpaceQuery<T> query, ChangeSet changeSet)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default uses the
ChangeModifiers.NONE
modifier.
change
in interface GigaSpace
query
- Query to search by.changeSet
- Changes to apply to the matched entry.ChangeResult
containing the details of the change operation affect.ChangeExtension
public <T> ChangeResult<T> change(ISpaceQuery<T> query, ChangeSet changeSet, ChangeModifiers modifiers)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default uses the
ChangeModifiers.NONE
modifier.
change
in interface GigaSpace
query
- Query to search by.changeSet
- Changes to apply to the matched entry.modifiers
- one or a union of ChangeModifiers
ChangeResult
containing the details of the change operation affect.ChangeExtension
public <T> ChangeResult<T> change(ISpaceQuery<T> query, ChangeSet changeSet, long timeout)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default uses the
ChangeModifiers.NONE
modifier.
change
in interface GigaSpace
query
- Query to search by.changeSet
- Changes to apply to the matched entry.timeout
- The timeout of the operation, in milliseconds. If the entry is locked
by another transaction wait for the specified number of milliseconds for it
to be released.ChangeResult
containing the details of the change operation affect.ChangeExtension
public <T> ChangeResult<T> change(ISpaceQuery<T> query, ChangeSet changeSet, ChangeModifiers modifiers, long timeout)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default uses the
ChangeModifiers.NONE
modifier.
change
in interface GigaSpace
query
- Query to search by.changeSet
- Changes to apply to the matched entry.modifiers
- one or a union of ChangeModifiers
timeout
- The timeout of the operation, in milliseconds. If the entry is locked
by another transaction wait for the specified number of milliseconds for it
to be released.ChangeResult
containing the details of the change operation affect.ChangeExtension
public <T> Future<ChangeResult<T>> asyncChange(ISpaceQuery<T> query, ChangeSet changeSet)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
query
- Query to search by.changeSet
- Changes to apply to the matched entry.ChangeExtension
public <T> Future<ChangeResult<T>> asyncChange(ISpaceQuery<T> query, ChangeSet changeSet, AsyncFutureListener<ChangeResult<T>> listener)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
query
- Query to search by.changeSet
- Changes to apply to the matched entry.listener
- A listener to be notified when a result arrives.ChangeExtension
public <T> Future<ChangeResult<T>> asyncChange(ISpaceQuery<T> query, ChangeSet changeSet, long timeout)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
query
- Query to search by.changeSet
- Changes to apply to the matched entry.timeout
- The timeout of the operation, in milliseconds. If the entry is locked
by another transaction wait for the specified number of milliseconds for it
to be released.ChangeExtension
public <T> Future<ChangeResult<T>> asyncChange(ISpaceQuery<T> query, ChangeSet changeSet, long timeout, AsyncFutureListener<ChangeResult<T>> listener)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
query
- Query to search by.changeSet
- Changes to apply to the matched entry.timeout
- The timeout of the operation, in milliseconds. If the entry is locked
by another transaction wait for the specified number of milliseconds for it
to be released.listener
- A listener to be notified when a result arrives.ChangeExtension
public <T> Future<ChangeResult<T>> asyncChange(ISpaceQuery<T> query, ChangeSet changeSet, ChangeModifiers modifiers)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
query
- Query to search by.changeSet
- Changes to apply to the matched entry.modifiers
- one or a union of ChangeModifiers
ChangeExtension
public <T> Future<ChangeResult<T>> asyncChange(ISpaceQuery<T> query, ChangeSet changeSet, ChangeModifiers modifiers, AsyncFutureListener<ChangeResult<T>> listener)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
query
- Query to search by.changeSet
- Changes to apply to the matched entry.modifiers
- one or a union of ChangeModifiers
listener
- A listener to be notified when a result arrives.ChangeExtension
public <T> Future<ChangeResult<T>> asyncChange(ISpaceQuery<T> query, ChangeSet changeSet, ChangeModifiers modifiers, long timeout)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
query
- Query to search by.changeSet
- Changes to apply to the matched entry.modifiers
- one or a union of ChangeModifiers
timeout
- The timeout of the operation, in milliseconds. If the entry is locked
by another transaction wait for the specified number of milliseconds for it
to be released.ChangeExtension
public <T> Future<ChangeResult<T>> asyncChange(ISpaceQuery<T> query, ChangeSet changeSet, ChangeModifiers modifiers, long timeout, AsyncFutureListener<ChangeResult<T>> listener)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
query
- Query to search by.changeSet
- Changes to apply to the matched entry.modifiers
- one or a union of ChangeModifiers
timeout
- The timeout of the operation, in milliseconds. If the entry is locked
by another transaction wait for the specified number of milliseconds for it
to be released.listener
- A listener to be notified when a result arrives.ChangeExtension
public <T> ChangeResult<T> change(T template, ChangeSet changeSet)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default uses the
ChangeModifiers.NONE
modifier.
change
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classeschangeSet
- Changes to apply to the matched entry.ChangeResult
containing the details of the change operation affect.public <T> ChangeResult<T> change(T template, ChangeSet changeSet, ChangeModifiers modifiers)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default uses the
ChangeModifiers.NONE
modifier.
change
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classeschangeSet
- Changes to apply to the matched entry.modifiers
- one or a union of ChangeModifiers
ChangeResult
containing the details of the change operation affect.public <T> ChangeResult<T> change(T template, ChangeSet changeSet, long timeout)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default uses the
ChangeModifiers.NONE
modifier.
change
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classeschangeSet
- Changes to apply to the matched entry.timeout
- The timeout of the operation, in milliseconds. If the entry is locked
by another transaction wait for the specified number of milliseconds for it
to be released.ChangeResult
containing the details of the change operation affect.public <T> ChangeResult<T> change(T template, ChangeSet changeSet, ChangeModifiers modifiers, long timeout)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default uses the
ChangeModifiers.NONE
modifier.
change
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classeschangeSet
- Changes to apply to the matched entry.modifiers
- one or a union of ChangeModifiers
timeout
- The timeout of the operation, in milliseconds. If the entry is locked
by another transaction wait for the specified number of milliseconds for it
to be released.ChangeResult
containing the details of the change operation affect.public <T> Future<ChangeResult<T>> asyncChange(T template, ChangeSet changeSet)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classeschangeSet
- Changes to apply to the matched entry.public <T> Future<ChangeResult<T>> asyncChange(T template, ChangeSet changeSet, AsyncFutureListener<ChangeResult<T>> listener)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classeschangeSet
- Changes to apply to the matched entry.listener
- A listener to be notified when a result arrives.public <T> Future<ChangeResult<T>> asyncChange(T template, ChangeSet changeSet, long timeout)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classeschangeSet
- Changes to apply to the matched entry.timeout
- The timeout of the operation, in milliseconds. If the entry is locked
by another transaction wait for the specified number of milliseconds for it
to be released.public <T> Future<ChangeResult<T>> asyncChange(T template, ChangeSet changeSet, long timeout, AsyncFutureListener<ChangeResult<T>> listener)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classeschangeSet
- Changes to apply to the matched entry.timeout
- The timeout of the operation, in milliseconds. If the entry is locked
by another transaction wait for the specified number of milliseconds for it
to be released.listener
- A listener to be notified when a result arrives.public <T> Future<ChangeResult<T>> asyncChange(T template, ChangeSet changeSet, ChangeModifiers modifiers)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classeschangeSet
- Changes to apply to the matched entry.modifiers
- one or a union of ChangeModifiers
public <T> Future<ChangeResult<T>> asyncChange(T template, ChangeSet changeSet, ChangeModifiers modifiers, AsyncFutureListener<ChangeResult<T>> listener)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classeschangeSet
- Changes to apply to the matched entry.modifiers
- one or a union of ChangeModifiers
listener
- A listener to be notified when a result arrives.public <T> Future<ChangeResult<T>> asyncChange(T template, ChangeSet changeSet, ChangeModifiers modifiers, long timeout)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classeschangeSet
- Changes to apply to the matched entry.modifiers
- one or a union of ChangeModifiers
timeout
- The timeout of the operation, in milliseconds. If the entry is locked
by another transaction wait for the specified number of milliseconds for it
to be released.public <T> Future<ChangeResult<T>> asyncChange(T template, ChangeSet changeSet, ChangeModifiers modifiers, long timeout, AsyncFutureListener<ChangeResult<T>> listener)
GigaSpace
Modifiers can be used to specify behavior of the change operation, by default
uses the ChangeModifiers.NONE
modifier.
asyncChange
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classeschangeSet
- Changes to apply to the matched entry.modifiers
- one or a union of ChangeModifiers
timeout
- The timeout of the operation, in milliseconds. If the entry is locked
by another transaction wait for the specified number of milliseconds for it
to be released.listener
- A listener to be notified when a result arrives.public <T> LeaseContext<T>[] writeMultiple(T[] entries) throws org.springframework.dao.DataAccessException
GigaSpace
The entry will be written using the
default lease this interface is configured with (using the its factory). In order to
explicitly define the lease, please use GigaSpace.writeMultiple(Object[], long)
.
writeMultiple
in interface GigaSpace
entries
- The entries to write to the space.org.springframework.dao.DataAccessException
- In the event of a write error, DataAccessException will wrap a
WriteMultipleException, accessible via DataAccessException.getRootCause().public <T> LeaseContext<T>[] writeMultiple(T[] entries, WriteModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
writeMultiple
in interface GigaSpace
entries
- The entries to write to the space.modifiers
- one or a union of WriteModifiers
.org.springframework.dao.DataAccessException
- In the event of a write error, DataAccessException will wrap a
WriteMultipleException, accessible via DataAccessException.getRootCause().public <T> LeaseContext<T>[] writeMultiple(T[] entries, long lease) throws org.springframework.dao.DataAccessException
GigaSpace
writeMultiple
in interface GigaSpace
entries
- The entries to write to the space.lease
- The lease the entry will be written with, in milliseconds.org.springframework.dao.DataAccessException
- In the event of a write error, DataAccessException will wrap a
WriteMultipleException, accessible via DataAccessException.getRootCause().public <T> LeaseContext<T>[] writeMultiple(T[] entries, long lease, WriteModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
'returns'
for
possible return values.writeMultiple
in interface GigaSpace
entries
- the entries to write.lease
- the requested lease time, in millisecondsmodifiers
- one or a union of WriteModifiers
.Lease
on a successful write, or
null
if performed with NoWriteLease attribute. when WriteModifiers.UPDATE_OR_WRITE
modifier is applied,
LeaseContext.getObject()
returns: WriteModifiers.RETURN_PREV_ON_UPDATE
is used, otherwise
null) org.springframework.dao.DataAccessException
- In the event of a write error, DataAccessException will wrap a
WriteMultipleException, accessible via DataAccessException.getRootCause().public <T> LeaseContext<T>[] writeMultiple(T[] entries, long lease, long timeout, WriteModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
'returns'
for
possible return values.writeMultiple
in interface GigaSpace
entries
- the entries to write.lease
- the requested lease time, in millisecondstimeout
- The timeout of the update operations, in milliseconds. If entries are
locked by another transactionmodifiers
- one or a union of WriteModifiers
.Lease
on a successful write, or
null
if performed with NoWriteLease attribute. when WriteModifiers.UPDATE_OR_WRITE
modifier is applied,
LeaseContext.getObject()
returns: WriteModifiers.RETURN_PREV_ON_UPDATE
is used, otherwise
null) org.springframework.dao.DataAccessException
- In the event of a write error, DataAccessException will wrap a
WriteMultipleException, accessible via DataAccessException.getRootCause().public <T> LeaseContext<T>[] writeMultiple(T[] entries, long[] leases, WriteModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
'returns'
for
possible return values.writeMultiple
in interface GigaSpace
entries
- the entries to write.leases
- the requested lease time per entry, in millisecondsmodifiers
- one or a union of WriteModifiers
.Lease
on a successful write, or
null
if performed with NoWriteLease attribute. when WriteModifiers.UPDATE_OR_WRITE
modifier is applied,
LeaseContext.getObject()
returns: WriteModifiers.RETURN_PREV_ON_UPDATE
is used, otherwise
null) org.springframework.dao.DataAccessException
- In the event of a write error, DataAccessException will wrap a
WriteMultipleException, accessible via DataAccessException.getRootCause().public <T> LeaseContext<T>[] writeMultiple(T[] entries, long[] leases, long timeout, WriteModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
'returns'
for
possible return values.writeMultiple
in interface GigaSpace
entries
- the entries to write.leases
- the requested lease time per entry, in millisecondstimeout
- The timeout of the update operations, in milliseconds. If entries are
locked by another transactionmodifiers
- one or a union of WriteModifiers
.Lease
on a successful write, or
null
if performed with NoWriteLease attribute. when WriteModifiers.UPDATE_OR_WRITE
modifier is applied,
LeaseContext.getObject()
returns: WriteModifiers.RETURN_PREV_ON_UPDATE
is used, otherwise
null) org.springframework.dao.DataAccessException
- In the event of a write error, DataAccessException will wrap a
WriteMultipleException, accessible via DataAccessException.getRootCause().public <T> SpaceIterator<T> iterator(T template)
GigaSpace
iterator
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classespublic <T> SpaceIterator<T> iterator(T template, int batchSize)
GigaSpace
iterator
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classesbatchSize
- Maximum number of entries to fetch on each batch.public <T> SpaceIterator<T> iterator(T template, int batchSize, ReadModifiers modifiers)
GigaSpace
iterator
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classesbatchSize
- Maximum number of entries to fetch on each batch.modifiers
- one or a union of ReadModifiers
.public <T> SpaceIterator<T> iterator(T template, SpaceIteratorConfiguration spaceIteratorConfiguration)
GigaSpace
iterator
in interface GigaSpace
template
- The template used for matching. Matching is done against the template with
null
fields being. wildcards ("match anything") other fields
being values ("match exactly on the serialized form"). The template can also
be one of the different ISpaceQuery
classesspaceIteratorConfiguration
- SpaceIteratorConfiguration
.public <T> SpaceIterator<T> iterator(ISpaceQuery<T> template)
GigaSpace
public <T> SpaceIterator<T> iterator(ISpaceQuery<T> template, int batchSize)
GigaSpace
public <T> SpaceIterator<T> iterator(ISpaceQuery<T> template, int batchSize, ReadModifiers modifiers)
GigaSpace
iterator
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.batchSize
- Maximum number of entries to fetch on each batch.modifiers
- one or a union of ReadModifiers
.public <T> SpaceIterator<T> iterator(ISpaceQuery<T> template, SpaceIteratorConfiguration spaceIteratorConfiguration)
GigaSpace
iterator
in interface GigaSpace
template
- A query to be executed against the space. Most common one is SQLQuery
.spaceIteratorConfiguration
- SpaceIteratorConfiguration
.public <T extends Serializable> AsyncFuture<T> execute(Task<T> task)
GigaSpace
SpaceRouting
. In order to control the routing
externally, use GigaSpace.execute(org.openspaces.core.executor.Task, Object)
.
The
space that the task is executed within can be accessible by marking a field with type GigaSpace
using the TaskGigaSpace
annotation. Another option is by implementing the TaskGigaSpaceAware
interface.
Resource injection can be enabled by marking the task with AutowireTask
or with AutowireTaskMarker
.
Resources defined within processing unit (space node) the task is executed on are accessible
by using either the Autowired
or
javax.annotation.Resource annotations (assuming they are enabled using
context:annotation-config
). Bean life cycle methods, such as ClusterInfoAware
and ApplicationContextAware
are also available.
public <T extends Serializable> AsyncFuture<T> execute(Task<T> task, AsyncFutureListener<T> listener)
GigaSpace
SpaceRouting
. In order to control the routing
externally, use GigaSpace.execute(org.openspaces.core.executor.Task, Object)
.
The
space that the task is executed within can be accessible by marking a field with type GigaSpace
using the TaskGigaSpace
annotation. Another option is by implementing the TaskGigaSpaceAware
interface.
Resource injection can be enabled by marking the task with AutowireTask
or with AutowireTaskMarker
.
Resources defined within processing unit (space node) the task is executed on are accessible
by using either the Autowired
or
javax.annotation.Resource annotations (assuming they are enabled using
context:annotation-config
). Bean life cycle methods, such as ClusterInfoAware
and ApplicationContextAware
are also available.
public <T extends Serializable> AsyncFuture<T> execute(Task<T> task, Object routing)
GigaSpace
The routing object
itself does not have to be the actual routing value, but can be a POJO that defined a method
annotated with @SpaceRouting
annotation (this works well when wanting to use
entries as the routing parameters).
In order to control the using the Task itself,
use GigaSpace.execute(org.openspaces.core.executor.Task)
.
The space that the task is
executed within can be accessible by marking a field with type GigaSpace
using the TaskGigaSpace
annotation. Another option is by implementing the TaskGigaSpaceAware
interface.
Resource injection can be enabled by marking the task with AutowireTask
or with AutowireTaskMarker
.
Resources defined within processing unit (space node) the task is executed on are accessible
by using either the Autowired
or
javax.annotation.Resource annotations (assuming they are enabled using
context:annotation-config
). Bean life cycle methods, such as ClusterInfoAware
and ApplicationContextAware
are also available.
execute
in interface GigaSpace
task
- The task to executerouting
- The routing value that will control on which node the task will be executed
onget()
method will return the task value upon completion.public <T extends Serializable> AsyncFuture<T> execute(Task<T> task, Object routing, AsyncFutureListener<T> listener)
GigaSpace
The routing object
itself does not have to be the actual routing value, but can be a POJO that defined a method
annotated with @SpaceRouting
annotation (this works well when wanting to use
entries as the routing parameters).
In order to control the using the Task itself,
use GigaSpace.execute(org.openspaces.core.executor.Task)
.
The space that the task is
executed within can be accessible by marking a field with type GigaSpace
using the TaskGigaSpace
annotation. Another option is by implementing the TaskGigaSpaceAware
interface.
Resource injection can be enabled by marking the task with AutowireTask
or with AutowireTaskMarker
.
Resources defined within processing unit (space node) the task is executed on are accessible
by using either the Autowired
or
javax.annotation.Resource annotations (assuming they are enabled using
context:annotation-config
). Bean life cycle methods, such as ClusterInfoAware
and ApplicationContextAware
are also available.
execute
in interface GigaSpace
task
- The task to executerouting
- The routing value that will control on which node the task will be executed
onlistener
- A listener to be notified when execution completesget()
method will return the task value upon completion.public <T extends Serializable,R> AsyncFuture<R> execute(DistributedTask<T,R> task, Object... routings)
GigaSpace
AsyncResultsReducer.reduce(java.util.List)
operation. The
routing object itself does not have to be the actual routing value, but can be a POJO that
defined a method annotated with @SpaceRouting
annotation (this works well when
wanting to use entries as the routing parameters).
The task can optionally implement
AsyncResultFilter
that can control if tasks should continue to
accumulate or it should break and execute the reduce operation on the results received so
far.
The future actual result will be the reduced result of the execution, or the exception thrown during during the reduce operation. The moderator can be used as a mechanism to listen for results as they arrive.
The last parameter can be of type AsyncFutureListener
which, this case, it will be used to register a
listener to be notified of the result.
The space that the task is executed within can
be accessible by marking a field with type GigaSpace
using the
TaskGigaSpace
annotation. Another option is by
implementing the TaskGigaSpaceAware
interface.
Resource injection can be enabled by marking the task with AutowireTask
or with AutowireTaskMarker
.
Resources defined within processing unit (space node) the task is executed on are accessible
by using either the Autowired
or
javax.annotation.Resource annotations (assuming they are enabled using
context:annotation-config
). Bean life cycle methods, such as ClusterInfoAware
and ApplicationContextAware
are also available.
execute
in interface GigaSpace
task
- The task to executeroutings
- A list of routing values, each resulting in an execution of the task on the
space node it corresponds toget()
method will return the task value upon completion.public <T extends Serializable,R> AsyncFuture<R> execute(DistributedTask<T,R> task)
GigaSpace
AsyncResultsReducer.reduce(java.util.List)
operation. The
task can optionally implement AsyncResultFilter
that can control
if tasks should continue to accumulate or it should break and execute the reduce operation on
the results received so far.
The future actual result will be the reduced result of the execution, or the exception thrown during during the reduce operation. The moderator can be used as a mechanism to listen for results as they arrive.
The space that the task
is executed within can be accessible by marking a field with type GigaSpace
using the TaskGigaSpace
annotation. Another option is by implementing the TaskGigaSpaceAware
interface.
Resource injection can be enabled by marking the task with AutowireTask
or with AutowireTaskMarker
.
Resources defined within processing unit (space node) the task is executed on are accessible
by using either the Autowired
or
javax.annotation.Resource annotations (assuming they are enabled using
context:annotation-config
). Bean life cycle methods, such as ClusterInfoAware
and ApplicationContextAware
are also available.
public <T extends Serializable,R> AsyncFuture<R> execute(DistributedTask<T,R> task, AsyncFutureListener<R> listener)
public <T extends Serializable,R> AsyncFuture<R> distExecute(DistributedTask<T,R> task, AsyncFutureListener<R> listener)
public <T extends Serializable,R> ExecutorBuilder<T,R> executorBuilder(AsyncResultsReducer<T,R> reducer)
GigaSpace
The reducer can optionally implement AsyncResultFilter
that
can control if tasks should continue to accumulate or it should break and execute the reduce
operation on the results received so far.
The space that the task is executed within
can be accessible by marking a field with type GigaSpace
using
the TaskGigaSpace
annotation. Another option is by
implementing the TaskGigaSpaceAware
interface.
Resource injection can be enabled by marking the task with AutowireTask
or with AutowireTaskMarker
.
Resources defined within processing unit (space node) the task is executed on are accessible
by using either the Autowired
or
javax.annotation.Resource annotations (assuming they are enabled using
context:annotation-config
). Bean life cycle methods, such as ClusterInfoAware
and ApplicationContextAware
are also available.
executorBuilder
in interface GigaSpace
reducer
- The reducer to reduce the results of all the different tasks added.public Transaction getCurrentTransaction()
GigaSpace
null
if no transaction is in
progress.getCurrentTransaction
in interface GigaSpace
public <T> AsyncFutureListener<T> wrapListener(AsyncFutureListener<T> listener, Transaction tx)
public <T> AsyncFuture<T> wrapFuture(AsyncFuture<T> future, Transaction tx)
wrapFuture
in interface InternalGigaSpace
public <T> ReadByIdsResult<T> readByIds(Class<T> clazz, Object[] ids)
GigaSpace
Note, if the
space is partitioned and the Class defines that routing is not done via the Id property, the
operation will broadcast to all partitions. Use GigaSpace.readByIds(Class, Object[], Object)
to specify the routing explicitly and avoid broadcast if needed.
public <T> ReadByIdsResult<T> readByIds(Class<T> clazz, Object[] ids, Object routing, ReadModifiers modifiers)
GigaSpace
ReadModifiers
. Note, if the space is partitioned and the
Class defines that routing is not done via the Id property, the operation will be routed
according to routingKey
. If it is null, the operation will broadcast to all
partitions.
ReadModifiers.FIFO
is not supported by this operation - the
results are always ordered in correlation with the input IDs array.
readByIds
in interface GigaSpace
clazz
- The class.ids
- The object IDs array.routing
- The routing of the provided object IDs.modifiers
- The read modifier to use (One or several of ReadModifiers
).public <T> ReadByIdsResult<T> readByIds(Class<T> clazz, Object[] ids, Object[] routings, ReadModifiers modifiers)
GigaSpace
ReadModifiers
. Note, if the space is partitioned and the
Class defines that routing is not done via the Id property, the operation will be routed
according to routingKeys
. If it is null, the operation will broadcast to all
partitions. routingKeys
should be correlated with ids
, i.e. their
length should be the same, and the routing key of ID i in the IDs array is the element at
position i in the routing keys array.
ReadModifiers.FIFO
is not supported by
this operation - the results are always ordered in correlation with the input IDs array.
readByIds
in interface GigaSpace
clazz
- The class type.ids
- The objects\ IDs array.routings
- The object routing keys array.modifiers
- The read modifier to use (One or several of ReadModifiers
).public <T> ReadByIdsResult<T> readByIds(Class<T> clazz, Object[] ids, Object routing)
GigaSpace
Note, if the space is partitioned and the Class defines that routing is not done via the
Id property, the operation will be routed according to routingKey
. If it is
null, the operation will broadcast to all partitions.
public <T> ReadByIdsResult<T> readByIds(Class<T> clazz, Object[] ids, Object[] routings)
GigaSpace
Note, if the space is partitioned and the Class defines that routing is not done via
the Id property, the operation will be routed according to routingKeys
. If it is
null, the operation will broadcast to all partitions. routingKeys
should be
correlated with ids
, i.e. their length should be the same, and the routing key
of ID i in the IDs array is the element at position i in the routing keys array.
public <T> ReadByIdsResult<T> readByIds(IdsQuery<T> query) throws org.springframework.dao.DataAccessException
GigaSpace
public <T> ReadByIdsResult<T> readByIds(IdsQuery<T> query, ReadModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
ReadModifiers
.readByIds
in interface GigaSpace
query
- Query to search by.modifiers
- The read modifier to use (One or several of ReadModifiers
).org.springframework.dao.DataAccessException
public <T> TakeByIdsResult<T> takeByIds(Class<T> clazz, Object[] ids, Object routing, TakeModifiers modifiers)
GigaSpace
ReadModifiers
. Note, if the space is partitioned and
the Class defines that routing is not done via the Id property, the operation will be routed
according to routingKey
. If it is null, the operation will broadcast to all
partitions.
ReadModifiers.FIFO
is not supported by this operation - the
results are always ordered in correlation with the input IDs array.
takeByIds
in interface GigaSpace
clazz
- The class.ids
- The object IDs array.routing
- The routing of the provided object IDs.modifiers
- The read modifier to use (One or several of ReadModifiers
).public <T> TakeByIdsResult<T> takeByIds(Class<T> clazz, Object[] ids, Object[] routings, TakeModifiers modifiers)
GigaSpace
ReadModifiers
. Note, if the space is partitioned and
the Class defines that routing is not done via the Id property, the operation will be routed
according to routingKeys
. If it is null, the operation will broadcast to all
partitions. routingKeys
should be correlated with ids
, i.e. their
length should be the same, and the routing key of ID i in the IDs array is the element at
position i in the routing keys array.
ReadModifiers.FIFO
is not supported by
this operation - the results are always ordered in correlation with the input IDs array.
takeByIds
in interface GigaSpace
clazz
- The class type.ids
- The objects\ IDs array.routings
- The object routing keys array.modifiers
- The read modifier to use (One or several of ReadModifiers
).public <T> TakeByIdsResult<T> takeByIds(Class<T> clazz, Object[] ids)
GigaSpace
Note, if the space is partitioned and the Class defines that routing is not done via the
Id property, the operation will broadcast to all partitions. Use GigaSpace.readByIds(Class,
Object[], Object)
to specify the routing explicitly and avoid broadcast if needed.
public <T> TakeByIdsResult<T> takeByIds(Class<T> clazz, Object[] ids, Object routing)
GigaSpace
Note, if the space is partitioned and the Class defines that routing is not done via
the Id property, the operation will be routed according to routingKey
. If it is
null, the operation will broadcast to all partitions.
public <T> TakeByIdsResult<T> takeByIds(Class<T> clazz, Object[] ids, Object[] routings)
GigaSpace
Note, if the space is partitioned and the Class defines that routing is not
done via the Id property, the operation will be routed according to routingKeys
.
If it is null, the operation will broadcast to all partitions. routingKeys
should be correlated with ids
, i.e. their length should be the same, and the
routing key of ID i in the IDs array is the element at position i in the routing keys array.
public <T> TakeByIdsResult<T> takeByIds(IdsQuery<T> query) throws org.springframework.dao.DataAccessException
GigaSpace
public <T> TakeByIdsResult<T> takeByIds(IdsQuery<T> query, TakeModifiers modifiers) throws org.springframework.dao.DataAccessException
GigaSpace
ReadModifiers
.takeByIds
in interface GigaSpace
query
- Query to search by.modifiers
- The read modifier to use (One or several of ReadModifiers
).org.springframework.dao.DataAccessException
public DataEventSession newDataEventSession()
GigaSpace
newDataEventSession
in interface GigaSpace
public DataEventSession newDataEventSession(EventSessionConfig config)
GigaSpace
newDataEventSession
in interface GigaSpace
config
- The configuration settings for the new data event session.public GigaSpaceTypeManager getTypeManager()
GigaSpace
getTypeManager
in interface GigaSpace
GigaSpaceTypeManager
public void setQuiesceToken(QuiesceToken token)
setQuiesceToken
in interface GigaSpace
public void setMVCCGenerationsState(MVCCGenerationsState generationsState)
setMVCCGenerationsState
in interface GigaSpace
public <T> ISpaceQuery<T> prepareTemplate(Object template)
GigaSpace
prepareTemplate
in interface GigaSpace
template
- to be translated into ISpaceQuery
ISpaceQuery
which represents the
translated templateGigaSpace.snapshot(Object)
public void close() throws IOException
IOException
public AsyncFuture<SpaceDataSourceLoadResult> asyncLoad(SpaceDataSourceLoadRequest spaceDataSourceLoadRequest)
GigaSpace
SpaceDataSource
on demand
The Space data source is created with SpaceDataSourceFactory
Loaded data can be adapted using the SpaceTypeSchemaAdapter
asyncLoad
in interface GigaSpace
spaceDataSourceLoadRequest
- SpaceDataSourceLoadRequest
Copyright © GigaSpaces.