edu.iu.dsc.tws.executor.threading

Class StreamingSharingExecutor

java.lang.Object

edu.iu.dsc.tws.executor.threading.ThreadSharingExecutor

edu.iu.dsc.tws.executor.threading.StreamingSharingExecutor

All Implemented Interfaces:

IExecutor, FaultAcceptable

Direct Known Subclasses:

DedicatedComStreamingExecutor

public class StreamingSharingExecutor
extends ThreadSharingExecutor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	StreamingSharingExecutor.StreamWorker

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	notStopped

Fields inherited from class edu.iu.dsc.tws.executor.threading.ThreadSharingExecutor

channel, config, executionHook, executionPlan, numThreads, threads

Constructor Summary

Constructors

Constructor and Description
StreamingSharingExecutor(Config cfg, int workerId, TWSChannel channel, ExecutionPlan plan, IExecutionHook hook)

Method Summary

Modifier and Type	Method and Description
boolean	closeExecution() Wait for the execution to complete
boolean	execute(boolean close) Execute the specific plan
boolean	isNotStopped()
boolean	runExecution() Specific implementation needs to implement this method
IExecution	runIExecution() Specific implementation needs to implement this method

Methods inherited from class edu.iu.dsc.tws.executor.threading.ThreadSharingExecutor

close, execute, getExecutionPlan, iExecute

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.iu.dsc.tws.api.compute.executor.IExecutor

onFault

Field Detail

notStopped

protected boolean notStopped

Constructor Detail

StreamingSharingExecutor

public StreamingSharingExecutor(Config cfg,
                                int workerId,
                                TWSChannel channel,
                                ExecutionPlan plan,
                                IExecutionHook hook)

Method Detail

runExecution

public boolean runExecution()

Description copied from class: ThreadSharingExecutor

Specific implementation needs to implement this method

Specified by:

runExecution in class ThreadSharingExecutor

Returns:

weather we executed successfully

execute

public boolean execute(boolean close)

Description copied from interface: IExecutor

Execute the specific plan

Returns:

true if accepted

runIExecution

public IExecution runIExecution()

Description copied from class: ThreadSharingExecutor

Specific implementation needs to implement this method

Specified by:

runIExecution in class ThreadSharingExecutor

Returns:

weather we executed successfully

closeExecution

public boolean closeExecution()

Description copied from interface: IExecutor

Wait for the execution to complete

Returns:

true if successful

isNotStopped

public boolean isNotStopped()