edu.iu.dsc.tws.api.compute.executor

Interface IExecutor

All Superinterfaces:

FaultAcceptable

All Known Implementing Classes:

AllSharingBatchExecutor, AllSharingStremingExecutor, BatchSharingExecutor, BatchSharingExecutor2, DedicatedComStreamingExecutor, DedidatedBatchExecutor, StreamingAllSharingExecutor, StreamingAllSharingExecutor2, StreamingSharingExecutor, ThreadSharingExecutor

public interface IExecutor
extends FaultAcceptable

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
default void	onFault(Fault fault) We are notifying that there is an error in the system and we need to terminate the current execution.

Method Detail

execute

boolean execute()

Execute the specific plan

Returns:

true if accepted

execute

boolean execute(boolean close)

Execute the specific plan

Returns:

true if accepted

iExecute

IExecution iExecute()

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

Returns:

an execution or null if not accepted

closeExecution

boolean closeExecution()

Wait for the execution to complete

Returns:

true if successful

close

void close()

Terminate the executor

onFault

default void onFault(Fault fault)
              throws Twister2Exception

We are notifying that there is an error in the system and we need to terminate the current execution.

Specified by:

onFault in interface FaultAcceptable

Parameters:

fault - the error code

Throws:

Twister2Exception - if an exception occurs while processing the fault

getExecutionPlan

ExecutionPlan getExecutionPlan()

Get the execution plan associated with this executor

Returns:

the execution plan