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

Class DedicatedComStreamingExecutor

java.lang.Object

edu.iu.dsc.tws.executor.threading.ThreadSharingExecutor

edu.iu.dsc.tws.executor.threading.StreamingSharingExecutor

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

All Implemented Interfaces:

IExecutor, FaultAcceptable

public class DedicatedComStreamingExecutor
extends StreamingSharingExecutor

This is a dedicated communication thread based streaming executor that halts execution in case of an error.

Nested Class Summary

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

StreamingSharingExecutor.StreamWorker

Field Summary

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

notStopped

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

channel, config, executionHook, executionPlan, numThreads, threads

Constructor Summary

Constructors

Constructor and Description
DedicatedComStreamingExecutor(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.StreamingSharingExecutor

closeExecution, execute, runExecution, runIExecution

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

close, execute, getExecutionPlan, iExecute

Methods inherited from class java.lang.Object

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

Constructor Detail

DedicatedComStreamingExecutor

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

Method Detail

isNotStopped

public boolean isNotStopped()

Overrides:

isNotStopped in class StreamingSharingExecutor

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