public class PredictionReduceTask extends BaseCompute implements Collector
| Constructor and Description |
|---|
PredictionReduceTask(OperationMode operationMode) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
execute(IMessage message)
Execute with an incoming message
|
DataPartition<?> |
get()
get the collected valued
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitget, getCollectibleNamesendExecutepublic PredictionReduceTask(OperationMode operationMode)
public DataPartition<?> get()
Collector