I'm trying to create an API to get results from build() but anyway I'm stuck on the StreamTransformation which is essential to implement slotSharingGroup(...). I have to provide it from the main class.
Tony Wei wrote > 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 < > kinn6aer@ > >: > >> 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/ >> -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
