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