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> 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)
|
Copyright © 2016 Actian Corporation. All Rights Reserved.