Hi Andrea, I don't think you need to touch `StreamTransformation`. If you can get the result from build(), you can do the same thing I mentioned above: casting it as SingleOutputStreamOperator. Then, you can pass it to select function to add the next operator, and get the result to add another slotSharing group.
Best Regards, Tony Wei 2017-10-27 17:18 GMT+08:00 AndreaKinn <kinn6...@hotmail.it>: > 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/ >
