public static class KMeansConnectedDataflowExample.KMeansDriver extends BaseDriver
| Constructor and Description |
|---|
KMeansDriver() |
| 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