flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From AndreaKinn <kinn6...@hotmail.it>
Subject Re: StreamTransformation<T> object
Date Fri, 27 Oct 2017 09:18:27 GMT
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 &lt;

> kinn6aer@

> &gt;:
> 
>> 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/

Mime
View raw message