edu.iu.dsc.tws.executor.threading.ft

Class AllSharingBatchExecutor

java.lang.Object

edu.iu.dsc.tws.executor.threading.BatchSharingExecutor2

edu.iu.dsc.tws.executor.threading.ft.AllSharingBatchExecutor

All Implemented Interfaces:

IExecutor, FaultAcceptable

public class AllSharingBatchExecutor
extends BatchSharingExecutor2

Nested Class Summary

Nested classes/interfaces inherited from class edu.iu.dsc.tws.executor.threading.BatchSharingExecutor2

BatchSharingExecutor2.BatchWorker, BatchSharingExecutor2.CommunicationWorker

Field Summary

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

executionHook, notStopped, plan

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
boolean	isNotStopped()
void	onFault(Fault fault) We are notifying that there is an error in the system and we need to terminate the current execution.

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

close, closeExecution, execute, execute, getExecutionPlan, iExecute, runExecution, runIExecution

Methods inherited from class java.lang.Object

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

Constructor Detail

AllSharingBatchExecutor

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

Method Detail

isNotStopped

public boolean isNotStopped()

Overrides:

isNotStopped in class BatchSharingExecutor2

onFault

public void onFault(Fault fault)
             throws Twister2Exception

Description copied from interface: IExecutor

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

Parameters:

fault - the error code

Throws:

Twister2Exception - if an exception occurs while processing the fault