public static class IncrementalLearningSkeleton.Predictor extends Object implements CoMapFunction<Integer,Double[],Integer>
By default emits the Integer 0 for every newData and the Integer 1 for every model update.
Constructor and Description |
---|
Predictor() |
Modifier and Type | Method and Description |
---|---|
protected Double[] |
getBatchModel() |
Integer |
map1(Integer value)
This method is called for each element in the first of the connected streams.
|
Integer |
map2(Double[] value)
This method is called for each element in the second of the connected streams.
|
protected Integer |
predict(Integer inTuple) |
public Integer map1(Integer value)
CoMapFunction
map1
in interface CoMapFunction<Integer,Double[],Integer>
value
- The stream elementpublic Integer map2(Double[] value)
CoMapFunction
map2
in interface CoMapFunction<Integer,Double[],Integer>
value
- The stream elementprotected Double[] getBatchModel()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.