Package | Description |
---|---|
com.gigaspaces.client |
Deprecated: use
org.openspaces.core instead. |
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 TakeModifiers |
TakeModifiers.EVICT_ONLY
Remove matching entries from memory only (do not remove from the underlying EDS).
|
static TakeModifiers |
TakeModifiers.FIFO
Search for matching entries using First-In-First-Out order.
|
static TakeModifiers |
TakeModifiers.FIFO_GROUPING_POLL
Search for matching entries in the FIFO group indicated in the template.
|
static TakeModifiers |
TakeModifiers.IF_EXISTS
Blocks only if there's a matching entry which is locked by another transaction.
|
static TakeModifiers |
TakeModifiers.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
TakeMultipleException which contains the partial results, which is the default behavior).
|
static TakeModifiers |
TakeModifiers.MEMORY_ONLY_SEARCH
Search for matching entries in cache memory only (do not use the underlying EDS).
|
static TakeModifiers |
TakeModifiers.NONE
Empty - use operation default behavior.
|
Modifier and Type | Method and Description |
---|---|
TakeModifiers |
TakeModifiers.add(TakeModifiers modifiers)
Creates a new modifiers instance which is a union of the specified modifiers and this
instance.
|
protected TakeModifiers |
TakeModifiers.create(int modifiers) |
TakeModifiers |
TakeModifiers.remove(TakeModifiers modifiers)
Creates a new modifiers instance which excludes the specified modifiers from this instance.
|
Modifier and Type | Method and Description |
---|---|
TakeModifiers |
TakeModifiers.add(TakeModifiers modifiers)
Creates a new modifiers instance which is a union of the specified modifiers and this
instance.
|
boolean |
TakeModifiers.contains(TakeModifiers modifiers)
Checks if the specified modifier is set.
|
TakeModifiers |
TakeModifiers.remove(TakeModifiers modifiers)
Creates a new modifiers instance which excludes the specified modifiers from this instance.
|
Constructor and Description |
---|
TakeModifiers(TakeModifiers... modifiers)
Creates a new modifiers from the specified modifiers.
|
TakeModifiers(TakeModifiers modifiers1,
TakeModifiers modifiers2)
Creates a new modifiers from the specified modifiers.
|
TakeModifiers(TakeModifiers modifiers1,
TakeModifiers modifiers2,
TakeModifiers modifiers3)
Creates a new modifiers from the specified modifiers.
|
Modifier and Type | Method and Description |
---|---|
TakeModifiers |
DefaultGigaSpace.getDefaultTakeModifiers() |
TakeModifiers |
GigaSpaceConfigurer.getDefaultTakeModifiers() |
TakeModifiers |
GigaSpace.getDefaultTakeModifiers()
Gets the default
TakeModifiers set during this GigaSpace configuration. |
Modifier and Type | Method and Description |
---|---|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncTake(ISpaceQuery<T> template,
long timeout,
TakeModifiers modifiers) |
<T> AsyncFuture<T> |
GigaSpace.asyncTake(ISpaceQuery<T> template,
long timeout,
TakeModifiers modifiers)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncTake(ISpaceQuery<T> template,
long timeout,
TakeModifiers modifiers,
AsyncFutureListener<T> listener) |
<T> AsyncFuture<T> |
GigaSpace.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> |
DefaultGigaSpace.asyncTake(T template,
long timeout,
TakeModifiers modifiers) |
<T> AsyncFuture<T> |
GigaSpace.asyncTake(T template,
long timeout,
TakeModifiers modifiers)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncTake(T template,
long timeout,
TakeModifiers modifiers,
AsyncFutureListener<T> listener) |
<T> AsyncFuture<T> |
GigaSpace.asyncTake(T template,
long timeout,
TakeModifiers modifiers,
AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner.
|
GigaSpaceConfigurer |
GigaSpaceConfigurer.defaultTakeModifiers(TakeModifiers defaultTakeModifiers)
Set the default
TakeModifiers to be used for take operations on the GigaSpace
instance. |
void |
DefaultGigaSpace.setDefaultTakeModifiers(TakeModifiers modifiers)
Sets the default
TakeModifiers when excecution DefaultGigaSpace.take(Object) |
void |
GigaSpaceFactoryBean.setDefaultTakeModifiers(TakeModifiers[] defaultTakeModifiers)
Set the default
TakeModifiers to be used for take operations on the GigaSpace
instance. |
<T> T |
DefaultGigaSpace.take(ISpaceQuery<T> template,
long timeout,
TakeModifiers modifiers) |
<T> T |
GigaSpace.take(ISpaceQuery<T> template,
long timeout,
TakeModifiers modifiers)
Take (remove) any matching entry from the space, blocking until one exists.
|
<T> T |
DefaultGigaSpace.take(T template,
long timeout,
TakeModifiers modifiers) |
<T> T |
GigaSpace.take(T template,
long timeout,
TakeModifiers modifiers)
Take (remove) any matching entry from the space, blocking until one exists.
|
<T> T |
DefaultGigaSpace.takeById(Class<T> clazz,
Object id,
Object routing,
long timeout,
TakeModifiers modifiers) |
<T> T |
GigaSpace.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 |
DefaultGigaSpace.takeById(IdQuery<T> query,
long timeout,
TakeModifiers modifiers) |
<T> T |
GigaSpace.takeById(IdQuery<T> query,
long timeout,
TakeModifiers modifiers)
Take (remove) an object from the space matching the specified id query.
|
<T> TakeByIdsResult<T> |
DefaultGigaSpace.takeByIds(Class<T> clazz,
Object[] ids,
Object[] routings,
TakeModifiers modifiers) |
<T> TakeByIdsResult<T> |
GigaSpace.takeByIds(Class<T> clazz,
Object[] ids,
Object[] routingKeys,
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> |
DefaultGigaSpace.takeByIds(Class<T> clazz,
Object[] ids,
Object routing,
TakeModifiers modifiers) |
<T> TakeByIdsResult<T> |
GigaSpace.takeByIds(Class<T> clazz,
Object[] ids,
Object routingKey,
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> |
DefaultGigaSpace.takeByIds(IdsQuery<T> query,
TakeModifiers modifiers) |
<T> TakeByIdsResult<T> |
GigaSpace.takeByIds(IdsQuery<T> query,
TakeModifiers modifiers)
Take (remove) objects from the space matching the specified IDs query, with the provided
ReadModifiers . |
<T> T |
DefaultGigaSpace.takeIfExists(ISpaceQuery<T> template,
long timeout,
TakeModifiers modifiers) |
<T> T |
GigaSpace.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 |
DefaultGigaSpace.takeIfExists(T template,
long timeout,
TakeModifiers modifiers) |
<T> T |
GigaSpace.takeIfExists(T template,
long timeout,
TakeModifiers modifiers)
Take (remove) any matching entry from the space, returning
null if there
currently is none. |
<T> T |
DefaultGigaSpace.takeIfExistsById(Class<T> clazz,
Object id,
Object routing,
long timeout,
TakeModifiers modifiers) |
<T> T |
GigaSpace.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 |
DefaultGigaSpace.takeIfExistsById(IdQuery<T> query,
long timeout,
TakeModifiers modifiers) |
<T> T |
GigaSpace.takeIfExistsById(IdQuery<T> query,
long timeout,
TakeModifiers modifiers)
Take (remove) an object from the space matching the specified id query.
|
<T> T[] |
DefaultGigaSpace.takeMultiple(ISpaceQuery<T> template,
int maxEntries,
TakeModifiers modifiers) |
<T> T[] |
GigaSpace.takeMultiple(ISpaceQuery<T> template,
int maxEntries,
TakeModifiers modifiers)
Takes (removes) all the entries matching the specified template from this space.
|
<T> T[] |
DefaultGigaSpace.takeMultiple(T template,
int maxEntries,
TakeModifiers modifiers) |
<T> T[] |
GigaSpace.takeMultiple(T template,
int maxEntries,
TakeModifiers modifiers)
Takes (removes) all the entries matching the specified template from this space.
|
Modifier and Type | Method and Description |
---|---|
static <T> CompletableFuture<T> |
AsyncExtension.asyncTake(GigaSpace gigaSpace,
ISpaceQuery<T> template,
long timeout,
TimeUnit timeUnit,
TakeModifiers modifiers) |
static <T> CompletableFuture<T> |
AsyncExtension.asyncTake(GigaSpace gigaSpace,
T template,
long timeout,
TimeUnit timeUnit,
TakeModifiers modifiers) |
Copyright © GigaSpaces.