Package | Description |
---|---|
com.actian.dataflow.cal.yarn.server | |
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
com.pervasive.datarush.cal.dr |
Modifier and Type | Method and Description |
---|---|
protected <R> MonitoredFuture<R> |
YarnClusterExecutor.createFuture(DistributedCallableBatch<R> batch,
List<CommandHandleInfo> handles,
ExecutionOptions options) |
Modifier and Type | Method and Description |
---|---|
<T> MonitoredFuture<T> |
DistributedExecutorService.submit(DistributedCallable<T> callable,
ExecutionOptions options)
Asynchronously invokes the given callable.
|
<T> MonitoredFuture<T> |
DistributedExecutorService.submit(DistributedCallableBatch<T> callable,
ExecutionOptions options)
Asynchronously invokes the given callable.
|
<T> MonitoredFuture<T> |
JobExecutorService.submit(JobCallable<T> callable)
Does the following:
Starts the job master if not already started.
Invokes the init method on the server side.
Starts execution on the server side
Returns a handle for monitoring execution
|
<T> MonitoredFuture<T> |
DistributedExecutorService.submitMaster(MonitoredCallable<T> callable)
Asynchronous, local, and non-parallel submission of the given callable.
|
Modifier and Type | Method and Description |
---|---|
static <S> List<S> |
ExecutionUtil.getStatus(List<? extends MonitoredFuture<S>> futures)
Invokes
getStatus() on each element in the provided
list of futures, returning a list of results or throwing an exception if there are any failures. |
Modifier and Type | Class and Description |
---|---|
class |
FaultTolerantFuture<R> |
class |
RemoteMonitoredFuture<R> |
Modifier and Type | Method and Description |
---|---|
protected <R> MonitoredFuture<R> |
PseudoDistributedClusterExecutor.createFuture(DistributedCallableBatch<R> batch,
List<CommandHandleInfo> handles,
ExecutionOptions options) |
protected <R> MonitoredFuture<R> |
DRClusterExecutor.createFuture(DistributedCallableBatch<R> batch,
List<CommandHandleInfo> handles,
ExecutionOptions options) |
protected abstract <R> MonitoredFuture<R> |
AbstractDRClusterExecutor.createFuture(DistributedCallableBatch<R> batch,
List<CommandHandleInfo> handles,
ExecutionOptions options) |
<R> MonitoredFuture<R> |
AbstractDRClusterExecutor.submit(DistributedCallable<R> command,
ExecutionOptions options) |
<R> MonitoredFuture<R> |
AbstractDRClusterExecutor.submit(DistributedCallableBatch<R> command,
ExecutionOptions options) |
<T> MonitoredFuture<T> |
AbstractDRJobExecutor.submit(JobCallable<T> callable) |
<T> MonitoredFuture<T> |
AbstractDRClusterExecutor.submitMaster(MonitoredCallable<T> command) |
Copyright © 2016 Actian Corporation. All Rights Reserved.