T
- Type of Node/Task IDR
- Type of Node/Task resultpublic interface Dexecutor<T,R> extends DependencyAware<T>
DefaultDexecutor
Modifier and Type | Method and Description |
---|---|
ExecutionResults<T,R> |
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
|
addAsDependencyToAllInitialNodes, addAsDependentOnAllLeafNodes, addDependency, addIndependent
ExecutionResults<T,R> execute(ExecutionConfig config)
addDepen***
apisconfig
- based on which execution should proceed.ExecutionResults
the resultsvoid recoverExecution(ExecutionConfig config)
config
- based on which execution would recoverCopyright © 2016–2018 Dexecutor. All rights reserved.