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

Class AllSharingStremingExecutor

java.lang.Object

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

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

All Implemented Interfaces:

IExecutor, FaultAcceptable

public class AllSharingStremingExecutor
extends StreamingAllSharingExecutor

Nested Class Summary

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

StreamingAllSharingExecutor.CommunicationWorker, StreamingAllSharingExecutor.StreamWorker

Field Summary

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

executionHook, notStopped

Constructor Summary

Constructors

Constructor and Description
AllSharingStremingExecutor(Config cfg, int workerId, TWSChannel channel, ExecutionPlan executionPlan, 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.StreamingAllSharingExecutor

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

AllSharingStremingExecutor

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

Method Detail

isNotStopped

public boolean isNotStopped()

Overrides:

isNotStopped in class StreamingAllSharingExecutor

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