public static class ParallelDataFlowsExample.ParallelDataflowsDriver extends BaseDriver
Constructor and Description |
---|
ParallelDataflowsDriver() |
Modifier and Type | Method and Description |
---|---|
void |
execute(CDFWEnv cdfwEnv) |
allWorkersJoined, execute, workerMessageReceived
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getMessages, getState
public void execute(CDFWEnv cdfwEnv)
execute
in class BaseDriver