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, wait
get, getCollectibleNames
endExecute
public PredictionReduceTask(OperationMode operationMode)
public DataPartition<?> get()
Collector