flink-htm icon indicating copy to clipboard operation
flink-htm copied to clipboard

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

Open Andrea-Giordano opened this issue 8 years ago • 2 comments

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.

Andrea-Giordano avatar Sep 02 '17 11:09 Andrea-Giordano

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

EronWright avatar Sep 06 '17 22:09 EronWright

Cheers @EronWright! Thanks for tending house 👍

rhyolight avatar Sep 07 '17 16:09 rhyolight