edu.iu.dsc.tws.executor.threading

Class StreamingAllSharingExecutor2

java.lang.Object

edu.iu.dsc.tws.executor.threading.StreamingAllSharingExecutor2

All Implemented Interfaces:

IExecutor, FaultAcceptable

public class StreamingAllSharingExecutor2
extends java.lang.Object
implements IExecutor

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
protected IExecutionHook	executionHook The execution hook

Constructor Summary

Constructors

Constructor and Description
StreamingAllSharingExecutor2(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	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

executionHook

protected IExecutionHook executionHook

The execution hook

Constructor Detail

StreamingAllSharingExecutor2

public StreamingAllSharingExecutor2(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

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

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

runExecution

public boolean runExecution()

Execution Method for Batch Tasks

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

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