Package | Description |
---|---|
com.gigaspaces.async |
Provides GigaSpaces asynchronous operations related interfaces.
|
com.gigaspaces.async.internal | |
com.gigaspaces.client.iterator.cursor | |
com.gigaspaces.internal.client.spaceproxy.executors | |
com.gigaspaces.internal.cluster.node.impl.replica | |
com.gigaspaces.internal.extension | |
com.gigaspaces.internal.remoting.routing.clustered | |
com.gigaspaces.internal.server.space.repartitioning | |
com.gigaspaces.internal.space.actions | |
com.gigaspaces.internal.space.requests | |
org.openspaces.core.executor.internal | |
org.openspaces.core.executor.juc | |
org.openspaces.core.executor.support | |
org.openspaces.core.transaction.internal | |
org.openspaces.events.support | |
org.openspaces.pu.container.jee.jetty.session | |
org.openspaces.remoting |
A package including OpenSpaces support for Sync and Async remoting inspired by other Spring remoting
integrations.
|
Modifier and Type | Method and Description |
---|---|
AsyncResult<T> |
AsyncResultFilterEvent.getCurrentResult()
Returns the current result that caused this event.
|
AsyncResult<T>[] |
AsyncResultFilterEvent.getReceivedResults()
Returns the received results without the current result.
|
Modifier and Type | Method and Description |
---|---|
void |
AsyncFutureListener.onResult(AsyncResult<T> result)
A callback when a result of an async invocation arrives.
|
Modifier and Type | Method and Description |
---|---|
R |
AsyncResultsReducer.reduce(List<AsyncResult<T>> results) |
Constructor and Description |
---|
AsyncResultFilterEvent(AsyncResult<T> currentResult,
AsyncResult<T>[] receivedResults,
int totalExpectedResults)
Constructs a new async result filter event
|
AsyncResultFilterEvent(AsyncResult<T> currentResult,
AsyncResult<T>[] receivedResults,
int totalExpectedResults)
Constructs a new async result filter event
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultAsyncResult<T>
Default container for async result
|
Modifier and Type | Method and Description |
---|---|
void |
CompoundFuture.onResult(AsyncResult<T> result) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceIteratorBatchResultProvider.addAsyncBatchResult(AsyncResult<SpaceIteratorBatchResult> spaceIteratorBatchAsyncResult) |
void |
SpaceIteratorBatchResultListener.onResult(AsyncResult<SpaceIteratorBatchResult> result) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceCopyReplicaRunnable.onResult(AsyncResult<Collection<ISpaceReplicaData>> result) |
Modifier and Type | Method and Description |
---|---|
SpaceResponseInfo |
WaitForDataDrainTask.reduce(List<AsyncResult<SpaceResponseInfo>> asyncResults) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterRemoteOperationRouter.AsyncOperationExecutor.onResult(AsyncResult<T> asyncResult) |
Modifier and Type | Method and Description |
---|---|
SpaceResponseInfo |
CopyChunksTask.reduce(List<AsyncResult<SpaceResponseInfo>> asyncResults) |
SpaceResponseInfo |
DeleteChunksTask.reduce(List<AsyncResult<SpaceResponseInfo>> asyncResults) |
Modifier and Type | Method and Description |
---|---|
GetTypeDescriptorActionInfo |
GetTypeDescriptorActionInfo.reduce(List<AsyncResult<GetTypeDescriptorActionInfo>> results) |
Modifier and Type | Method and Description |
---|---|
R |
InternalDistributedSpaceTaskWrapper.reduce(List<AsyncResult<T>> asyncResults) |
Modifier and Type | Method and Description |
---|---|
R |
CallableDistributedTaskAdapter.reduce(List<AsyncResult<T>> results)
Delegates the call to the provided reducer.
|
R |
RunnableDistributedTaskAdapter.reduce(List<AsyncResult<T>> results)
Delegates the call to the provided reducer.
|
Modifier and Type | Method and Description |
---|---|
void |
WaitForAnyListener.onResult(AsyncResult<T> result) |
void |
WaitForAllListener.onResult(AsyncResult<T> result) |
Modifier and Type | Method and Description |
---|---|
R |
AvgTask.reduce(List<AsyncResult<T>> results)
Performs the actual sum operation by delegating to its internal
SumReducer . |
T |
MinReducer.reduce(List<AsyncResult<T>> results) |
R |
SumReducer.reduce(List<AsyncResult<T>> results) |
T |
MaxTask.reduce(List<AsyncResult<T>> results)
Performs the actual sum operation by delegating to its internal
SumReducer . |
R |
SimpleDelegatingDistributedTask.reduce(List<AsyncResult<T>> asyncResults) |
R |
SumTask.reduce(List<AsyncResult<T>> results)
Performs the actual sum operation by delegating to its internal
SumReducer . |
R |
AvgReducer.reduce(List<AsyncResult<T>> results) |
T |
MaxReducer.reduce(List<AsyncResult<T>> results) |
T |
MinTask.reduce(List<AsyncResult<T>> results)
Performs the actual sum operation by delegating to its internal
SumReducer . |
R |
PrivilegedDistributedTask.reduce(List<AsyncResult<T>> results)
Reduces the provided task under access controls.
|
Constructor and Description |
---|
AsyncResultFuture(AsyncResult<T> result) |
Modifier and Type | Method and Description |
---|---|
void |
TransactionalAsyncFutureListener.onPostCommitTransaction(AsyncResult<T> asyncResult) |
void |
TransactionalAsyncFutureListener.onPostRollbackTransaction(AsyncResult<T> asyncResult) |
void |
InternalAsyncFutureListener.onResult(AsyncResult<T> asyncResult) |
void |
TransactionalAsyncFutureListener.onTransactionalResult(AsyncResult<T> asyncResult,
org.springframework.transaction.TransactionStatus txStatus) |
Modifier and Type | Method and Description |
---|---|
Boolean |
UnregisterDistributedEventContainerTask.reduce(List<AsyncResult<Boolean>> results) |
Object |
RegisterDistributedEventContainerTask.reduce(List<AsyncResult<Serializable>> asyncResults) |
Modifier and Type | Method and Description |
---|---|
HashSet<String> |
FindNonExpiredSessionsTask.reduce(List<AsyncResult<HashSet<String>>> asyncResults) |
Modifier and Type | Method and Description |
---|---|
List<AsyncResult<ExecutorRemotingTask.InternalExecutorResult<T>>> |
ExecutorRemotingTask.reduce(List<AsyncResult<ExecutorRemotingTask.InternalExecutorResult<T>>> results) |
Modifier and Type | Method and Description |
---|---|
List<AsyncResult<ExecutorRemotingTask.InternalExecutorResult<T>>> |
ExecutorRemotingTask.reduce(List<AsyncResult<ExecutorRemotingTask.InternalExecutorResult<T>>> results) |
Copyright © GigaSpaces.