| Package | Description |
|---|---|
| com.actian.dataflow.cal.yarn.server | |
| com.pervasive.datarush.cal.dr |
| Modifier and Type | Method and Description |
|---|---|
protected <R> List<CommandHandleInfo> |
YarnClusterExecutor.submit(DistributedCallableBatch<R> command,
List<AbstractDRClusterExecutor.CommandServiceHelper> services) |
| Modifier and Type | Method and Description |
|---|---|
protected <R> MonitoredFuture<R> |
YarnClusterExecutor.createFuture(DistributedCallableBatch<R> batch,
List<CommandHandleInfo> handles,
ExecutionOptions options) |
| Modifier and Type | Field and Description |
|---|---|
protected List<CommandHandleInfo> |
RemoteMonitoredFuture.handles |
| Modifier and Type | Method and Description |
|---|---|
CommandHandleInfo |
AbstractDRClusterExecutor.CommandServiceHelper.submit(DistributedCallableBatch<?> command) |
CommandHandleInfo |
AbstractDRJobExecutor.JobMasterHelper.submit(JobCallable<?> jobCallable) |
| Modifier and Type | Method and Description |
|---|---|
protected List<CommandHandleInfo> |
RemoteMonitoredFuture.handleFailed(CommandHandleInfo handle,
RMIException e) |
protected List<CommandHandleInfo> |
FaultTolerantFuture.handleFailed(CommandHandleInfo handle,
RMIException e) |
protected <R> List<CommandHandleInfo> |
PseudoDistributedClusterExecutor.submit(DistributedCallableBatch<R> command,
List<AbstractDRClusterExecutor.CommandServiceHelper> services) |
protected <R> List<CommandHandleInfo> |
DRClusterExecutor.submit(DistributedCallableBatch<R> command,
List<AbstractDRClusterExecutor.CommandServiceHelper> services) |
protected abstract <R> List<CommandHandleInfo> |
AbstractDRClusterExecutor.submit(DistributedCallableBatch<R> command,
List<AbstractDRClusterExecutor.CommandServiceHelper> services)
Overridden to either do parallel submit (for dist) or non-parallel (for pseudo-dist)
|
| Modifier and Type | Method and Description |
|---|---|
protected List<CommandHandleInfo> |
RemoteMonitoredFuture.handleFailed(CommandHandleInfo handle,
RMIException e) |
protected List<CommandHandleInfo> |
FaultTolerantFuture.handleFailed(CommandHandleInfo handle,
RMIException e) |
| 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) |
| Constructor and Description |
|---|
RemoteMonitoredFuture(CommandHandleInfo handle) |
| Constructor and Description |
|---|
FaultTolerantFuture(DistributedCallableBatch<R> batch,
List<CommandHandleInfo> handles,
DRClusterExecutor executor,
ExecutionOptions options) |
RemoteMonitoredFuture(ResultMerger<R> merger,
List<CommandHandleInfo> handles) |
Copyright © 2015 Actian Corporation. All Rights Reserved.