com.pervasive.datarush.cal.dr

Class PseudoDistributedClusterExecutor

java.lang.Object

com.pervasive.datarush.cal.dr.AbstractDRClusterExecutor

com.pervasive.datarush.cal.dr.PseudoDistributedClusterExecutor

All Implemented Interfaces:

DistributedExecutorService, PseudoDistributedExecutorService

public final class PseudoDistributedClusterExecutor
extends AbstractDRClusterExecutor
implements PseudoDistributedExecutorService

Nested Class Summary

Nested classes/interfaces inherited from class com.pervasive.datarush.cal.dr.AbstractDRClusterExecutor

AbstractDRClusterExecutor.CommandServiceHelper, AbstractDRClusterExecutor.CommandServiceInfo

Field Summary

Fields inherited from class com.pervasive.datarush.cal.dr.AbstractDRClusterExecutor

allocationProvider, DIST_MUTEX, distExecutors, fileClient, jobSpec

Constructor Summary

Constructors

Constructor and Description
PseudoDistributedClusterExecutor(FileClient fileClient, JobSpecifier jobSpec)

Method Summary

Methods

Modifier and Type	Method and Description
protected <R> MonitoredFuture<R>	createFuture(DistributedCallableBatch<R> batch, List<CommandHandleInfo> handles, ExecutionOptions options)
DistributedCallableContextBatch	getContexts() Returns the contexts corresponding to all distributed contexts.
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)

Methods inherited from class com.pervasive.datarush.cal.dr.AbstractDRClusterExecutor

drfsRoots, ensureInitialNodeAllocation, execute, execute, fullPartitions, getMasterContext, getMasterResources, getNonParallelStatistics, startShutdown, submit, submit, submitMaster

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.pervasive.datarush.cal.DistributedExecutorService

ensureInitialNodeAllocation, execute, execute, getMasterContext, submit, submit, submitMaster

Constructor Detail

PseudoDistributedClusterExecutor

public PseudoDistributedClusterExecutor(FileClient fileClient,
                                JobSpecifier jobSpec)

Method Detail

start

protected List<AbstractDRClusterExecutor.CommandServiceInfo> start()

Specified by:

start in class AbstractDRClusterExecutor

createFuture

protected <R> MonitoredFuture<R> createFuture(DistributedCallableBatch<R> batch,
                                  List<CommandHandleInfo> handles,
                                  ExecutionOptions options)

Specified by:

createFuture in class AbstractDRClusterExecutor

getContexts

public DistributedCallableContextBatch getContexts()

Description copied from interface: PseudoDistributedExecutorService

Returns the contexts corresponding to all distributed contexts. This is possible only when running pseudo-distributed since when running distributed, the context is only available on the remote side.

Specified by:

getContexts in interface PseudoDistributedExecutorService

Returns:

the context

submit

protected <R> List<CommandHandleInfo> submit(DistributedCallableBatch<R> command,
                                 List<AbstractDRClusterExecutor.CommandServiceHelper> services)

Description copied from class: AbstractDRClusterExecutor

Overridden to either do parallel submit (for dist) or non-parallel (for pseudo-dist)

Specified by:

submit in class AbstractDRClusterExecutor

Returns: