com.github.dexecutor.core

Interface Dexecutor<T extends Comparable<T>,R>

Type Parameters:

T - Type of Node/Task ID

R - Type of Node/Task result

All Superinterfaces:

DependencyAware<T>

All Known Implementing Classes:

DefaultDexecutor

public interface Dexecutor<T extends Comparable<T>,R>
extends DependencyAware<T>

Main Interface for Dexecutor framework, It provides api to build the graph and and to kick off the execution.

Author:

Nadeem Mohammad

See Also:

DefaultDexecutor

Method Summary

Modifier and Type	Method and Description
void	execute(ExecutionConfig config) Kicks off the execution of the nodes based on the dependency graph constructed, using addDepen*** apis
void	print(Traversar<T,R> traversar, TraversarAction<T,R> action) Prints the graph into the writer, using the traversar
void	recoverExecution(ExecutionConfig config) After a dexecutor crash, create a new instance of dexecutor and call this method for recovery

Methods inherited from interface com.github.dexecutor.core.graph.DependencyAware

addAsDependencyToAllInitialNodes, addAsDependentOnAllLeafNodes, addDependency, addIndependent

Method Detail

execute

void execute(ExecutionConfig config)

Kicks off the execution of the nodes based on the dependency graph constructed, using addDepen*** apis

Parameters:

config - based on which execution should proceed.

recoverExecution

void recoverExecution(ExecutionConfig config)

After a dexecutor crash, create a new instance of dexecutor and call this method for recovery

Parameters:

config - based on which execution would recover

print

void print(Traversar<T,R> traversar,
           TraversarAction<T,R> action)

Prints the graph into the writer, using the traversar

Parameters:

traversar - would traverse the graph

action - callback which would be called based on traverse