Hi Andrea, The `learn` operator is defined in this method [1]. If you need to set its slotSharing group, you should add `slotSharingGroup(...)` behind line 97 [2] or a new API to get the result from `inferenceStreamBuilder.build()`.
Best Regards, Tony Wei [1] https://github.com/htm-community/flink-htm/blob/master/flink-htm-streaming-java/src/main/java/org/numenta/nupic/flink/streaming/api/HTMStream.java#L148 [2] https://github.com/htm-community/flink-htm/blob/master/flink-htm-streaming-java/src/main/java/org/numenta/nupic/flink/streaming/api/HTMStream.java#L97 2017-10-26 17:36 GMT+08:00 AndreaKinn <kinn6...@hotmail.it>: > Can you be clearer about this part? > > I'm really appreciating your help > > > Tony Wei wrote > > you need to refactor `HTMStream` to expose > > `InferenceStreamBuilder.build()`. > > > > > > -- > Sent from: http://apache-flink-user-mailing-list-archive.2336050. > n4.nabble.com/ >
