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