Package | Description |
---|---|
com.gigaspaces.client |
Deprecated: use
org.openspaces.core instead. |
com.gigaspaces.client.internal | |
com.gigaspaces.client.iterator |
Provides classes to configure SpaceIterator.
|
org.openspaces.core |
Top level core package holding main OpenSpaces API for Space (GigaSpace) and Map (GigaMap) and
the ability to create it.
|
org.openspaces.extensions |
Modifier and Type | Field and Description |
---|---|
static ReadModifiers |
ReadModifiers.DIRTY_READ
When a search for matching entries encounters an entry locked under a different uncommitted
transaction, the lock is ignored and matching is performed on the uncommitted state.
|
static ReadModifiers |
ReadModifiers.EXCLUSIVE_READ_LOCK
The resulting entries are locked, blocking update/remove from other transactions.
|
static ReadModifiers |
ReadModifiers.FIFO
Search for matching entries using First-In-First-Out order.
|
static ReadModifiers |
ReadModifiers.FIFO_GROUPING_POLL
Search for matching entries in the FIFO group indicated in the template.
|
static ReadModifiers |
ReadModifiers.IF_EXISTS
Blocks only if there's a matching entry which is locked by another transaction.
|
static ReadModifiers |
ReadModifiers.IGNORE_PARTIAL_FAILURE
If one or more partitions are not available during the operation, ignore them and return
partial results based on the available partitions (instead of throwing an
ReadMultipleException which contains the partial results, which is the default behavior).
|
static ReadModifiers |
ReadModifiers.MEMORY_ONLY_SEARCH
Search for matching entries in cache memory only (do not use the underlying EDS).
|
static ReadModifiers |
ReadModifiers.NONE
Empty - use operation default behavior.
|
static ReadModifiers |
ReadModifiers.READ_COMMITTED
When a search for matching entries encounters an entry locked under a different uncommitted
transaction, the lock is honored and matching is performed on the committed state.
|
static ReadModifiers |
ReadModifiers.REPEATABLE_READ
When a search for matching entries encounters an entry locked under a different uncommitted
transaction, the lock is honored and the entry is skipped (if the operation is invoked with a
timeout it will block until the entry will be released or the timeout expires).
|
Modifier and Type | Method and Description |
---|---|
ReadModifiers |
ReadModifiers.add(ReadModifiers modifiers)
Creates a new modifiers instance which is a union of the specified modifiers and this
instance.
|
protected ReadModifiers |
ReadModifiers.create(int modifiers) |
ReadModifiers |
ReadModifiers.remove(ReadModifiers modifiers)
Creates a new modifiers instance which excludes the specified modifiers from this instance.
|
ReadModifiers |
ReadModifiers.setIsolationLevel(ReadModifiers isolationLevel)
Creates a new modifiers instance with the specified isolation level set and any other
isolation level unset.
|
Modifier and Type | Method and Description |
---|---|
ReadModifiers |
ReadModifiers.add(ReadModifiers modifiers)
Creates a new modifiers instance which is a union of the specified modifiers and this
instance.
|
boolean |
ReadModifiers.contains(ReadModifiers modifiers)
Checks if the specified modifier is set.
|
ReadModifiers |
ReadModifiers.remove(ReadModifiers modifiers)
Creates a new modifiers instance which excludes the specified modifiers from this instance.
|
ReadModifiers |
ReadModifiers.setIsolationLevel(ReadModifiers isolationLevel)
Creates a new modifiers instance with the specified isolation level set and any other
isolation level unset.
|
Constructor and Description |
---|
ReadModifiers(ReadModifiers... modifiers)
Creates a new modifiers from the specified modifiers.
|
ReadModifiers(ReadModifiers modifiers1,
ReadModifiers modifiers2)
Creates a new modifiers from the specified modifiers.
|
ReadModifiers(ReadModifiers modifiers1,
ReadModifiers modifiers2,
ReadModifiers modifiers3)
Creates a new modifiers from the specified modifiers.
|
Modifier and Type | Class and Description |
---|---|
class |
InternalReadModifiers |
Modifier and Type | Field and Description |
---|---|
static ReadModifiers |
InternalReadModifiers.RUN_ON_IO_THREAD
Indicates operation should run directly on i/o thread, instead of being submitted to the operations thread pool.
|
Modifier and Type | Method and Description |
---|---|
ReadModifiers |
SpaceIteratorConfiguration.getReadModifiers() |
Modifier and Type | Method and Description |
---|---|
SpaceIteratorConfiguration |
SpaceIteratorConfiguration.setReadModifiers(ReadModifiers readModifiers)
Sets the
ReadModifiers which allows to programmatically control the isolation level this iteration
* operation will be performed under. |
Modifier and Type | Method and Description |
---|---|
ReadModifiers |
GigaSpace.getDefaultReadModifiers()
Gets the default
ReadModifiers set during this GigaSpace configuration. |
ReadModifiers |
DefaultGigaSpace.getDefaultReadModifiers() |
ReadModifiers |
GigaSpaceConfigurer.getDefaultReadModifiers() |
static ReadModifiers |
IsolationLevelHelpers.toReadModifiers(int isolationLevel) |
Modifier and Type | Method and Description |
---|---|
<T> AsyncFuture<T> |
GigaSpace.asyncRead(ISpaceQuery<T> template,
long timeout,
ReadModifiers modifiers)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncRead(ISpaceQuery<T> template,
long timeout,
ReadModifiers modifiers) |
<T> AsyncFuture<T> |
GigaSpace.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> |
DefaultGigaSpace.asyncRead(ISpaceQuery<T> template,
long timeout,
ReadModifiers modifiers,
AsyncFutureListener<T> listener) |
<T> AsyncFuture<T> |
GigaSpace.asyncRead(T template,
long timeout,
ReadModifiers modifiers)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncRead(T template,
long timeout,
ReadModifiers modifiers) |
<T> AsyncFuture<T> |
GigaSpace.asyncRead(T template,
long timeout,
ReadModifiers modifiers,
AsyncFutureListener<T> listener)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncRead(T template,
long timeout,
ReadModifiers modifiers,
AsyncFutureListener<T> listener) |
GigaSpaceConfigurer |
GigaSpaceConfigurer.defaultReadModifiers(ReadModifiers defaultReadModifiers)
Set the default
ReadModifiers to be used for read operations on the GigaSpace
instance. |
<T> SpaceIterator<T> |
GigaSpace.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> |
DefaultGigaSpace.iterator(ISpaceQuery<T> template,
int batchSize,
ReadModifiers modifiers) |
<T> SpaceIterator<T> |
GigaSpace.iterator(T template,
int batchSize,
ReadModifiers modifiers)
Returns an iterator over the entries in the space which match the specified template.
|
<T> SpaceIterator<T> |
DefaultGigaSpace.iterator(T template,
int batchSize,
ReadModifiers modifiers) |
<T> T |
GigaSpace.read(ISpaceQuery<T> template,
long timeout,
ReadModifiers modifiers)
Read any matching object from the space, blocking until one exists.
|
<T> T |
DefaultGigaSpace.read(ISpaceQuery<T> template,
long timeout,
ReadModifiers modifiers) |
<T> T |
GigaSpace.read(T template,
long timeout,
ReadModifiers modifiers)
Read any matching object from the space, blocking until one exists.
|
<T> T |
DefaultGigaSpace.read(T template,
long timeout,
ReadModifiers modifiers) |
<T> T |
GigaSpace.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 |
DefaultGigaSpace.readById(Class<T> clazz,
Object id,
Object routing,
long timeout,
ReadModifiers modifiers) |
<T> T |
GigaSpace.readById(IdQuery<T> query,
long timeout,
ReadModifiers modifiers)
Read an object from the space matching the specified id query.
|
<T> T |
DefaultGigaSpace.readById(IdQuery<T> query,
long timeout,
ReadModifiers modifiers) |
<T> ReadByIdsResult<T> |
GigaSpace.readByIds(Class<T> clazz,
Object[] ids,
Object[] routingKeys,
ReadModifiers modifiers)
Read objects from the space matching their IDs, the specified class and the routing keys,
with the provided
ReadModifiers . |
<T> ReadByIdsResult<T> |
DefaultGigaSpace.readByIds(Class<T> clazz,
Object[] ids,
Object[] routings,
ReadModifiers modifiers) |
<T> ReadByIdsResult<T> |
GigaSpace.readByIds(Class<T> clazz,
Object[] ids,
Object routingKey,
ReadModifiers modifiers)
Read objects from the space matching their IDs, the specified class type and routing key,
with the provided
ReadModifiers . |
<T> ReadByIdsResult<T> |
DefaultGigaSpace.readByIds(Class<T> clazz,
Object[] ids,
Object routing,
ReadModifiers modifiers) |
<T> ReadByIdsResult<T> |
GigaSpace.readByIds(IdsQuery<T> query,
ReadModifiers modifiers)
Read objects from the space matching the specified IDs query, with the provided
ReadModifiers . |
<T> ReadByIdsResult<T> |
DefaultGigaSpace.readByIds(IdsQuery<T> query,
ReadModifiers modifiers) |
<T> T |
GigaSpace.readIfExists(ISpaceQuery<T> template,
long timeout,
ReadModifiers modifiers)
Read any matching object from the space, returning
null if there currently is
none. |
<T> T |
DefaultGigaSpace.readIfExists(ISpaceQuery<T> template,
long timeout,
ReadModifiers modifiers) |
<T> T |
GigaSpace.readIfExists(T template,
long timeout,
ReadModifiers modifiers)
Read any matching object from the space, returning
null if there currently is
none. |
<T> T |
DefaultGigaSpace.readIfExists(T template,
long timeout,
ReadModifiers modifiers) |
<T> T |
GigaSpace.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 |
DefaultGigaSpace.readIfExistsById(Class<T> clazz,
Object id,
Object routing,
long timeout,
ReadModifiers modifiers) |
<T> T |
GigaSpace.readIfExistsById(IdQuery<T> query,
long timeout,
ReadModifiers modifiers)
Read an object from the space matching the specified id query.
|
<T> T |
DefaultGigaSpace.readIfExistsById(IdQuery<T> query,
long timeout,
ReadModifiers modifiers) |
<T> T[] |
GigaSpace.readMultiple(ISpaceQuery<T> template,
int maxEntries,
ReadModifiers modifiers)
Read any matching entries from the space.
|
<T> T[] |
DefaultGigaSpace.readMultiple(ISpaceQuery<T> template,
int maxEntries,
ReadModifiers modifiers) |
<T> T[] |
GigaSpace.readMultiple(T template,
int maxEntries,
ReadModifiers modifiers)
Read any matching entries from the space.
|
<T> T[] |
DefaultGigaSpace.readMultiple(T template,
int maxEntries,
ReadModifiers modifiers) |
void |
DefaultGigaSpace.setDefaultReadModifiers(ReadModifiers modifiers)
Sets the default
ReadModifiers when excecution DefaultGigaSpace.read(Object) |
void |
GigaSpaceFactoryBean.setDefaultReadModifiers(ReadModifiers[] defaultReadModifiers)
Set the default
ReadModifiers to be used for read operations on the GigaSpace
instance. |
Modifier and Type | Method and Description |
---|---|
static <T> CompletableFuture<T> |
AsyncExtension.asyncRead(GigaSpace gigaSpace,
ISpaceQuery<T> template,
long timeout,
TimeUnit timeUnit,
ReadModifiers modifiers) |
static <T> CompletableFuture<T> |
AsyncExtension.asyncRead(GigaSpace gigaSpace,
T template,
long timeout,
TimeUnit timeUnit,
ReadModifiers modifiers) |
Copyright © GigaSpaces.