edu.iu.dsc.tws.executor.threading

Class StreamingAllSharingExecutor

java.lang.Object

edu.iu.dsc.tws.executor.threading.StreamingAllSharingExecutor

All Implemented Interfaces:

IExecutor, FaultAcceptable

Direct Known Subclasses:

AllSharingStremingExecutor

public class StreamingAllSharingExecutor
extends java.lang.Object
implements IExecutor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	StreamingAllSharingExecutor.CommunicationWorker
protected class	StreamingAllSharingExecutor.StreamWorker

Field Summary

Fields

Modifier and Type	Field and Description
protected IExecutionHook	executionHook The execution hook
protected boolean	notStopped not stopped

Constructor Summary

Constructors

Constructor and Description
StreamingAllSharingExecutor(Config cfg, int workerId, TWSChannel channel, ExecutionPlan executionPlan, IExecutionHook hook)

Method Summary

Modifier and Type	Method and Description
void	close() Terminate the executor
boolean	closeExecution() Wait for the execution to complete
boolean	execute() Execute the specific plan
boolean	execute(boolean close) Execute the specific plan
ExecutionPlan	getExecutionPlan() Get the execution plan associated with this executor
IExecution	iExecute() Asynchronously execute a plan, One need to call progress on the execution object returned to continue the execution
boolean	isNotStopped()
boolean	runExecution() Execution Method for Batch Tasks
IExecution	runIExecution()

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

not stopped

executionHook

protected IExecutionHook executionHook

The execution hook

Constructor Detail

StreamingAllSharingExecutor

public StreamingAllSharingExecutor(Config cfg,
                                   int workerId,
                                   TWSChannel channel,
                                   ExecutionPlan executionPlan,
                                   IExecutionHook hook)

Method Detail

execute

public boolean execute()

Description copied from interface: IExecutor

Execute the specific plan

Specified by:

execute in interface IExecutor

Returns:

true if accepted

execute

public boolean execute(boolean close)

Description copied from interface: IExecutor

Execute the specific plan

Specified by:

execute in interface IExecutor

Returns:

true if accepted

getExecutionPlan

public ExecutionPlan getExecutionPlan()

Description copied from interface: IExecutor

Get the execution plan associated with this executor

Specified by:

getExecutionPlan in interface IExecutor

Returns:

the execution plan

iExecute

public IExecution iExecute()

Description copied from interface: IExecutor

Asynchronously execute a plan, One need to call progress on the execution object returned to continue the execution

Specified by:

iExecute in interface IExecutor

Returns:

an execution or null if not accepted

close

public void close()

Description copied from interface: IExecutor

Terminate the executor

Specified by:

close in interface IExecutor

isNotStopped

public boolean isNotStopped()

runExecution

public boolean runExecution()

Execution Method for Batch Tasks

runIExecution

public IExecution runIExecution()

closeExecution

public boolean closeExecution()

Description copied from interface: IExecutor

Wait for the execution to complete

Specified by:

closeExecution in interface IExecutor

Returns:

true if successful