| 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 © 2024 Actian Corporation. All rights reserved.