htm-community / flink-htm

Distributed, streaming anomaly detection and prediction with HTM in Apache Flink
GNU Affero General Public License v3.0
136 stars 37 forks source link

Java - Overrided select() function defined in HTM.learn().select() never called. #22

Open Andrea-Giordano opened 7 years ago

Andrea-Giordano commented 7 years ago

Template:

DataStream<T> result = HTM.learn(stream, new Network())
                .select(new InferenceSelectFunction<R, T>() {
                                           @Override
                                            public T select(Tuple2<R, NetworkInference> inference) throws Exception {
                                    return inference.f1.getAnomalyScore();
                                             }
                });

The overrided select is never called. I verified that following the call hierarchy. This lead to no one output produced. Anyway, I verified the anomaly score, internally, is correctly computed.

Tried to resolve it, no great results reached. Please, fix it.

EronWright commented 7 years ago

@Andrea-Giordano I'm working with Andrea offline to understand the issue.

rhyolight commented 7 years ago

Cheers @EronWright! Thanks for tending house 👍