Package | Description |
---|---|
com.gigaspaces.async |
Provides GigaSpaces asynchronous operations related interfaces.
|
com.gigaspaces.async.internal | |
com.gigaspaces.internal.client.cache.localcache.actions | |
com.gigaspaces.internal.client.cache.localview.actions | |
com.gigaspaces.internal.client.spaceproxy | |
com.gigaspaces.internal.client.spaceproxy.actions | |
com.gigaspaces.internal.client.spaceproxy.executors | |
com.gigaspaces.internal.cluster.node.impl.router | |
com.gigaspaces.internal.cluster.node.impl.router.spacefinder | |
com.gigaspaces.internal.remoting | |
com.gigaspaces.internal.remoting.routing.partitioned | |
com.gigaspaces.lrmi.nio.async | |
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.core.executor.juc | |
org.openspaces.core.internal | |
org.openspaces.core.transaction.internal | |
org.openspaces.events.asyncpolling.receive |
Modifier and Type | Class and Description |
---|---|
class |
SettableFuture<T>
Created by Barak Bar Orion 19/08/14.
|
Modifier and Type | Method and Description |
---|---|
static <T,R> AsyncFuture<R> |
FutureFactory.create(AsyncFuture<T>[] futures,
AsyncResultsReducer<T,R> reducer) |
static <T,R> AsyncFuture<R> |
FutureFactory.create(AsyncFuture<T>[] futures,
AsyncResultsReducer<T,R> reducer,
AsyncResultFilter<T> moderator) |
Modifier and Type | Method and Description |
---|---|
static <T,R> AsyncFuture<R> |
FutureFactory.create(AsyncFuture<T>[] futures,
AsyncResultsReducer<T,R> reducer) |
static <T,R> AsyncFuture<R> |
FutureFactory.create(AsyncFuture<T>[] futures,
AsyncResultsReducer<T,R> reducer,
AsyncResultFilter<T> moderator) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFuture<T> |
class |
CompoundFuture<T,R>
a future implementation used to aggregate results from multiple Futures.
|
Constructor and Description |
---|
CompoundFuture(AsyncFuture<T>[] futures,
AsyncResultsReducer<T,R> reducer) |
CompoundFuture(AsyncFuture<T>[] futures,
AsyncResultsReducer<T,R> reducer,
AsyncResultFilter<T> moderator) |
Modifier and Type | Class and Description |
---|---|
class |
LocalCacheImplAsyncOperationsFuture<T>
Base class for dcache async futures, it registers with a custom listener per implementation and
delegates the result to the user supplied listener when the operation is considered done (Up to
the custom listener)
|
Modifier and Type | Method and Description |
---|---|
AsyncFuture<AddTypeIndexesResult> |
LocalCacheImplTypeDescriptorActionsExecutor.asyncAddIndexes(LocalCacheContainer spaceProxy,
AddTypeIndexesRequestInfo requestInfo) |
AsyncFuture<?> |
LocalCacheImplReadTakeAction.asyncRead(LocalCacheContainer spaceProxy,
ReadTakeAsyncProxyActionInfo actionInfo) |
AsyncFuture<?> |
LocalCacheImplReadTakeAction.asyncTake(LocalCacheContainer spaceProxy,
ReadTakeAsyncProxyActionInfo actionInfo) |
AsyncFuture |
LocalCacheImplAdminAction.execute(LocalCacheContainer spaceProxy,
SpaceTask task,
Object routing,
Transaction txn,
AsyncFutureListener listener) |
Modifier and Type | Method and Description |
---|---|
AsyncFuture<AddTypeIndexesResult> |
LocalViewImplTypeDescriptorActionsExecutor.asyncAddIndexes(LocalViewContainer spaceProxy,
AddTypeIndexesRequestInfo requestInfo) |
AsyncFuture<?> |
LocalViewImplReadTakeAction.asyncRead(LocalViewContainer spaceProxy,
ReadTakeAsyncProxyActionInfo actionInfo) |
AsyncFuture<?> |
LocalViewImplReadTakeAction.asyncTake(LocalViewContainer spaceProxy,
ReadTakeAsyncProxyActionInfo actionInfo) |
AsyncFuture |
LocalViewImplAdminAction.execute(LocalViewContainer spaceProxy,
SpaceTask task,
Object routing,
Transaction txn,
AsyncFutureListener listener) |
Modifier and Type | Method and Description |
---|---|
AsyncFuture<AddTypeIndexesResult> |
ISpaceProxy.asyncAddIndexes(String typeName,
SpaceIndex[] indexes,
AsyncFutureListener<AddTypeIndexesResult> listener) |
AsyncFuture<AddTypeIndexesResult> |
AbstractSpaceProxy.asyncAddIndexes(String typeName,
SpaceIndex[] indexes,
AsyncFutureListener<AddTypeIndexesResult> listener) |
AsyncFuture |
ISpaceProxy.asyncRead(Object template,
Transaction transaction,
long timeout,
int modifiers,
AsyncFutureListener listener)
Internal methods only.
|
AsyncFuture<?> |
AbstractSpaceProxy.asyncRead(Object template,
Transaction txn,
long timeout,
int modifiers,
AsyncFutureListener listener) |
AsyncFuture |
ISpaceProxy.asyncTake(Object template,
Transaction transaction,
long timeout,
int modifiers,
AsyncFutureListener listener)
Internal methods only.
|
AsyncFuture<?> |
AbstractSpaceProxy.asyncTake(Object template,
Transaction txn,
long timeout,
int modifiers,
AsyncFutureListener listener) |
AsyncFuture |
ISpaceProxy.execute(SpaceTask task,
Object routing,
Transaction tx,
AsyncFutureListener listener)
Executes a task on a single space.
|
AsyncFuture |
AbstractSpaceProxy.execute(SpaceTask task,
Object routing,
Transaction tx,
AsyncFutureListener listener) |
Modifier and Type | Method and Description |
---|---|
AsyncFuture<AddTypeIndexesResult> |
AbstractSpaceProxyActionManager.asyncAddIndexes(String typeName,
SpaceIndex[] indexes,
AsyncFutureListener<AddTypeIndexesResult> listener) |
AsyncFuture<?> |
AbstractSpaceProxyActionManager.asyncRead(Object template,
Transaction txn,
long timeout,
int modifiers,
AsyncFutureListener<?> listener) |
AsyncFuture<?> |
SpaceProxyImplReadTakeAction.asyncRead(SpaceProxyImpl spaceProxy,
ReadTakeAsyncProxyActionInfo actionInfo) |
abstract AsyncFuture<?> |
ReadTakeProxyAction.asyncRead(TSpaceProxy spaceProxy,
ReadTakeAsyncProxyActionInfo actionInfo) |
AsyncFuture<?> |
AbstractSpaceProxyActionManager.asyncTake(Object template,
Transaction txn,
long timeout,
int modifiers,
AsyncFutureListener<?> listener) |
AsyncFuture<?> |
SpaceProxyImplReadTakeAction.asyncTake(SpaceProxyImpl spaceProxy,
ReadTakeAsyncProxyActionInfo actionInfo) |
abstract AsyncFuture<?> |
ReadTakeProxyAction.asyncTake(TSpaceProxy spaceProxy,
ReadTakeAsyncProxyActionInfo actionInfo) |
AsyncFuture |
SpaceProxyImplAdminAction.execute(SpaceProxyImpl spaceProxy,
SpaceTask task,
Object routing,
Transaction txn,
AsyncFutureListener listener) |
abstract AsyncFuture |
AdminProxyAction.execute(TSpaceProxy spaceProxy,
SpaceTask task,
Object routing,
Transaction txn,
AsyncFutureListener listener) |
AsyncFuture |
AbstractSpaceProxyActionManager.executeTask(SpaceTask task,
Object routing,
Transaction tx,
AsyncFutureListener listener) |
Modifier and Type | Method and Description |
---|---|
AsyncFuture<AddTypeIndexesResult> |
SpaceProxyImplTypeDescriptorActionsExecutor.asyncAddIndexes(SpaceProxyImpl spaceProxy,
AddTypeIndexesRequestInfo requestInfo) |
abstract AsyncFuture<AddTypeIndexesResult> |
TypeDescriptorActionsProxyExecutor.asyncAddIndexes(TSpaceProxy spaceProxy,
AddTypeIndexesRequestInfo requestInfo) |
Modifier and Type | Method and Description |
---|---|
<T> AsyncFuture<T> |
IReplicationConnection.dispatchAsync(AbstractReplicationPacket<T> packet) |
<TR> AsyncFuture<TR> |
AbstractProxyBasedReplicationMonitoredConnection.dispatchAsync(AbstractReplicationPacket<TR> packet) |
<T> AsyncFuture<T> |
IAsyncContextProvider.getFutureContext(T syncResult,
Object proxy) |
<T> AsyncFuture<T> |
LRMIAsyncContextProvider.getFutureContext(T syncResult,
Object proxy) |
Modifier and Type | Method and Description |
---|---|
<T> AsyncFuture<T> |
ConnectionReference.dispatchAsync(AbstractReplicationPacket<T> packet) |
Modifier and Type | Class and Description |
---|---|
class |
RemoteOperationFutureListener<T extends RemoteOperationResult> |
Modifier and Type | Class and Description |
---|---|
class |
BroadcastOperationFutureListener<T extends RemoteOperationResult> |
class |
ScatterGatherOperationFutureListener<T extends RemoteOperationResult> |
Modifier and Type | Interface and Description |
---|---|
interface |
IFuture<T>
An internal interface extending the
AsyncFuture . |
Modifier and Type | Class and Description |
---|---|
class |
LRMIFuture<T>
A future implementation used to hold delayed result coming from one target.
|
Modifier and Type | Method and Description |
---|---|
AsyncFuture<AddTypeIndexesResult> |
DefaultGigaSpaceTypeManager.asyncAddIndex(String typeName,
SpaceIndex index) |
AsyncFuture<AddTypeIndexesResult> |
GigaSpaceTypeManager.asyncAddIndex(String typeName,
SpaceIndex index)
Adds the specified index to the specified type.
|
AsyncFuture<AddTypeIndexesResult> |
DefaultGigaSpaceTypeManager.asyncAddIndex(String typeName,
SpaceIndex index,
AsyncFutureListener<AddTypeIndexesResult> listener) |
AsyncFuture<AddTypeIndexesResult> |
GigaSpaceTypeManager.asyncAddIndex(String typeName,
SpaceIndex index,
AsyncFutureListener<AddTypeIndexesResult> listener)
Adds the specified index to the specified type.
|
AsyncFuture<AddTypeIndexesResult> |
DefaultGigaSpaceTypeManager.asyncAddIndexes(String typeName,
SpaceIndex[] indexes,
AsyncFutureListener<AddTypeIndexesResult> listener) |
AsyncFuture<AddTypeIndexesResult> |
GigaSpaceTypeManager.asyncAddIndexes(String typeName,
SpaceIndex[] indexes,
AsyncFutureListener<AddTypeIndexesResult> listener)
Adds the specified indexes to the specified type.
|
AsyncFuture<SpaceDataSourceLoadResult> |
DefaultGigaSpace.asyncLoad(SpaceDataSourceLoadRequest spaceDataSourceLoadRequest) |
AsyncFuture<SpaceDataSourceLoadResult> |
GigaSpace.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> |
DefaultGigaSpace.asyncRead(ISpaceQuery<T> template) |
<T> AsyncFuture<T> |
GigaSpace.asyncRead(ISpaceQuery<T> template)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncRead(ISpaceQuery<T> template,
AsyncFutureListener<T> listener) |
<T> AsyncFuture<T> |
GigaSpace.asyncRead(ISpaceQuery<T> template,
AsyncFutureListener<T> listener)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncRead(ISpaceQuery<T> template,
long timeout) |
<T> AsyncFuture<T> |
GigaSpace.asyncRead(ISpaceQuery<T> template,
long timeout)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncRead(ISpaceQuery<T> template,
long timeout,
AsyncFutureListener<T> listener) |
<T> AsyncFuture<T> |
GigaSpace.asyncRead(ISpaceQuery<T> template,
long timeout,
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) |
<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,
AsyncFutureListener<T> listener) |
<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(T template) |
<T> AsyncFuture<T> |
GigaSpace.asyncRead(T template)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncRead(T template,
AsyncFutureListener<T> listener) |
<T> AsyncFuture<T> |
GigaSpace.asyncRead(T template,
AsyncFutureListener<T> listener)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncRead(T template,
long timeout) |
<T> AsyncFuture<T> |
GigaSpace.asyncRead(T template,
long timeout)
Reads any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncRead(T template,
long timeout,
AsyncFutureListener<T> listener) |
<T> AsyncFuture<T> |
GigaSpace.asyncRead(T template,
long timeout,
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) |
<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,
AsyncFutureListener<T> listener) |
<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.asyncTake(ISpaceQuery<T> template) |
<T> AsyncFuture<T> |
GigaSpace.asyncTake(ISpaceQuery<T> template)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncTake(ISpaceQuery<T> template,
AsyncFutureListener<T> listener) |
<T> AsyncFuture<T> |
GigaSpace.asyncTake(ISpaceQuery<T> template,
AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncTake(ISpaceQuery<T> template,
long timeout) |
<T> AsyncFuture<T> |
GigaSpace.asyncTake(ISpaceQuery<T> template,
long timeout)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncTake(ISpaceQuery<T> template,
long timeout,
AsyncFutureListener<T> listener) |
<T> AsyncFuture<T> |
GigaSpace.asyncTake(ISpaceQuery<T> template,
long timeout,
AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<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) |
<T> AsyncFuture<T> |
GigaSpace.asyncTake(T template)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncTake(T template,
AsyncFutureListener<T> listener) |
<T> AsyncFuture<T> |
GigaSpace.asyncTake(T template,
AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncTake(T template,
long timeout) |
<T> AsyncFuture<T> |
GigaSpace.asyncTake(T template,
long timeout)
Take (remove) any matching entry from the space in an asynchronous manner.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.asyncTake(T template,
long timeout,
AsyncFutureListener<T> listener) |
<T> AsyncFuture<T> |
GigaSpace.asyncTake(T template,
long timeout,
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.
|
<T extends Serializable,R> |
DefaultGigaSpace.distExecute(DistributedTask<T,R> task,
AsyncFutureListener<R> listener) |
AsyncFuture<R> |
ExecutorBuilder.execute()
Executes all the given tasks (asynchronously) based on their execution mode and returns a
future allowing to retrieve the reduced operation of all the tasks.
|
<T extends Serializable,R> |
DefaultGigaSpace.execute(DistributedTask<T,R> task) |
<T extends Serializable,R> |
GigaSpace.execute(DistributedTask<T,R> task)
Executes the task on all the primary space nodes within the cluster (broadcast).
|
<T extends Serializable,R> |
DefaultGigaSpace.execute(DistributedTask<T,R> task,
AsyncFutureListener<R> listener) |
<T extends Serializable,R> |
DefaultGigaSpace.execute(DistributedTask<T,R> task,
Object... routings) |
<T extends Serializable,R> |
GigaSpace.execute(DistributedTask<T,R> task,
Object... routing)
Executes a task on all the nodes that correspond to the list of routing values.
|
<T extends Serializable> |
DefaultGigaSpace.execute(Task<T> task) |
<T extends Serializable> |
GigaSpace.execute(Task<T> task)
Executes a task on a specific space node.
|
<T extends Serializable> |
DefaultGigaSpace.execute(Task<T> task,
AsyncFutureListener<T> listener) |
<T extends Serializable> |
GigaSpace.execute(Task<T> task,
AsyncFutureListener<T> listener)
Executes a task on a specific space node.
|
<T extends Serializable> |
DefaultGigaSpace.execute(Task<T> task,
Object routing) |
<T extends Serializable> |
GigaSpace.execute(Task<T> task,
Object routing)
Executes a task on a specific space node.
|
<T extends Serializable> |
DefaultGigaSpace.execute(Task<T> task,
Object routing,
AsyncFutureListener<T> listener) |
<T extends Serializable> |
GigaSpace.execute(Task<T> task,
Object routing,
AsyncFutureListener<T> listener)
Executes a task on a specific space node.
|
<T> AsyncFuture<T> |
DefaultGigaSpace.wrapFuture(AsyncFuture<T> future,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
<T> AsyncFuture<T> |
DefaultGigaSpace.wrapFuture(AsyncFuture<T> future,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
<T> AsyncFuture<T> |
DefaultTaskExecutorService.submit(Callable<T> task) |
AsyncFuture<?> |
DefaultTaskExecutorService.submit(Runnable task) |
<T> AsyncFuture<T> |
DefaultTaskExecutorService.submit(Runnable task,
T result) |
Modifier and Type | Method and Description |
---|---|
<T> AsyncFuture<T> |
InternalGigaSpace.wrapFuture(AsyncFuture<T> future,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
<T> AsyncFuture<T> |
InternalGigaSpace.wrapFuture(AsyncFuture<T> future,
Transaction tx) |
Modifier and Type | Class and Description |
---|---|
class |
InternalAsyncFuture<T> |
Constructor and Description |
---|
InternalAsyncFuture(AsyncFuture<T> future,
GigaSpace gigaSpace) |
InternalAsyncFuture(AsyncFuture<T> future,
GigaSpace gigaSpace,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
AsyncFuture |
SingleReadAsyncOperationHandler.asyncReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout,
AsyncFutureListener listener)
Performs a single take usign
GigaSpace.asyncRead(Object) . |
AsyncFuture |
ExclusiveReadAsyncOperationHandler.asyncReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout,
AsyncFutureListener listener)
Performs a single take usign
GigaSpace.asyncRead(Object) under
exclusive read lock. |
AsyncFuture |
SingleTakeAsyncOperationHandler.asyncReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout,
AsyncFutureListener listener)
Performs a single take usign
GigaSpace.asyncTake(Object) . |
AsyncFuture |
AsyncOperationHandler.asyncReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout,
AsyncFutureListener listener)
Perform the async receive operation.
|
Copyright © GigaSpaces.