com.github.dexecutor.core

Interface Dexecutor<T extends Comparable<T>>

Type Parameters:

T - Type of Node/Task ID

R - Type of Node/Task result

All Known Implementing Classes:

DefaultDexecutor

public interface Dexecutor<T extends Comparable<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:

DefaultDependentTasksExecutor}

Method Summary

Methods

Modifier and Type	Method and Description
void	addAsDependencyToAllInitialNodes(T nodeValue) Adds the node as dependency to all initial nodes (at the time of adding), meaning this given node would be evaluated first and then all initial nodes would run in parallel
void	addAsDependentOnAllLeafNodes(T nodeValue) Adds the node as dependent on all leaf nodes (at the time of adding), meaning all leaf nodes would be evaluated first and then the given node
void	addDependency(T evalFirstValue, T evalAfterValue) Add Two dependent nodes into the graph, creating the nodes if not already present
void	addIndependent(T nodeValue) Add a node as independent, it does not require any dependent node
void	execute(ExecutionConfig config) Kicks off the execution of the nodes based on the dependency graph constructed, using addDepen*** apis
void	print(Writer writer) Prints the graph into the writer

Method Detail

addIndependent

void addIndependent(T nodeValue)

Add a node as independent, it does not require any dependent node

Parameters:

nodeValue -

addDependency

void addDependency(T evalFirstValue,
                 T evalAfterValue)

Add Two dependent nodes into the graph, creating the nodes if not already present

evalFirstValue would be executed first and then evalAfterValue

Parameters:

evalFirstValue -

evalAfterValue -

addAsDependentOnAllLeafNodes

void addAsDependentOnAllLeafNodes(T nodeValue)

Adds the node as dependent on all leaf nodes (at the time of adding), meaning all leaf nodes would be evaluated first and then the given node

Parameters:

nodeValue -

addAsDependencyToAllInitialNodes

void addAsDependencyToAllInitialNodes(T nodeValue)

Adds the node as dependency to all initial nodes (at the time of adding), meaning this given node would be evaluated first and then all initial nodes would run in parallel

Parameters:

nodeValue -

execute

void execute(ExecutionConfig config)

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

Parameters:

ExecutionConfig -

print

void print(Writer writer)

Prints the graph into the writer

Parameters:

writer -