public final class DRClusterExecutor extends AbstractDRClusterExecutor
AbstractDRClusterExecutor.CommandServiceHelper, AbstractDRClusterExecutor.CommandServiceInfo
allocationProvider, DIST_MUTEX, distExecutors, fileClient
Constructor and Description |
---|
DRClusterExecutor(FileClient fileClient,
JobSpecifier jobSpec,
ExecutorOptions execOptions,
NodeAllocationProvider allocationProvider,
ResourceAllocation masterResources) |
Modifier and Type | Method and Description |
---|---|
protected <R> MonitoredFuture<R> |
createFuture(DistributedCallableBatch<R> batch,
List<CommandHandleInfo> handles,
ExecutionOptions options) |
Map<String,Path> |
drfsRoots()
Returns a mapping from physical id to drfs roots for the physical id.
|
JobSpecifier |
getJobSpecifier() |
protected ResourceAllocation |
getMasterResources() |
void |
nodeFailed(String failedNode) |
protected ParallelStartupHelper |
parallelStartup() |
protected List<AbstractDRClusterExecutor.CommandServiceInfo> |
start() |
protected <R> List<CommandHandleInfo> |
submit(DistributedCallableBatch<R> command,
List<AbstractDRClusterExecutor.CommandServiceHelper> services)
Overridden to either do parallel submit (for dist) or non-parallel (for pseudo-dist)
|
ensureInitialNodeAllocation, execute, execute, fullPartitions, getMasterContext, getNonParallelStatistics, startShutdown, submit, submit, submitMaster
public DRClusterExecutor(FileClient fileClient, JobSpecifier jobSpec, ExecutorOptions execOptions, NodeAllocationProvider allocationProvider, ResourceAllocation masterResources)
protected final ParallelStartupHelper parallelStartup()
public JobSpecifier getJobSpecifier()
public Map<String,Path> drfsRoots()
drfsRoots
in class AbstractDRClusterExecutor
protected List<AbstractDRClusterExecutor.CommandServiceInfo> start()
start
in class AbstractDRClusterExecutor
public final void nodeFailed(String failedNode)
protected <R> MonitoredFuture<R> createFuture(DistributedCallableBatch<R> batch, List<CommandHandleInfo> handles, ExecutionOptions options)
createFuture
in class AbstractDRClusterExecutor
protected <R> List<CommandHandleInfo> submit(DistributedCallableBatch<R> command, List<AbstractDRClusterExecutor.CommandServiceHelper> services)
AbstractDRClusterExecutor
submit
in class AbstractDRClusterExecutor
protected ResourceAllocation getMasterResources()
getMasterResources
in class AbstractDRClusterExecutor
Copyright © 2016 Actian Corporation. All Rights Reserved.