Package | Description |
---|---|
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
Modifier and Type | Class and Description |
---|---|
class |
BatchExecutionException
Subclass of DistributedExecutionException that contains all the exceptions that occurred in one batch.
|
Modifier and Type | Method and Description |
---|---|
<T> T |
DistributedExecutorService.execute(DistributedCallable<T> command,
ExecutionOptions options)
Synchronously invokes the given callable.
|
<T> T |
DistributedExecutorService.execute(DistributedCallableBatch<T> command,
ExecutionOptions options)
Synchronously invokes the given callable.
|
static <T> List<T> |
ExecutionUtil.getResults(List<? extends Future<T>> futures)
Invokes
Future.get() on each element in the provided
list of futures, returning a list of results or throwing an exception if there are any failures. |
static <T> List<T> |
ExecutionUtil.getResults(List<? extends Future<T>> futures,
long timeout,
TimeUnit timeunit)
Invokes
Future.get() or Future.get(long, TimeUnit) on each element in the provided
list of futures, returning a list of results or throwing an exception if there are any failures. |
static <S> List<S> |
ExecutionUtil.getStatus(List<? extends MonitoredFuture<S>> futures)
Invokes
MonitoredFuture.getStatus() on each element in the provided
list of futures, returning a list of results or throwing an exception if there are any failures. |
Copyright © 2016 Actian Corporation. All rights reserved.