Hi Andrea,
I roughly read that external library[1], and I think the return object of
"select" function could be casted as `SingleOutputStreamOperator` type [2].
How about trying the following code?
DataStream<Tuple7<String, String, Date, String, String, Double, Double>>
LCxAccResult = HTM.learn(LCxAccStream, new Harness.AnomalyNetwork())
.select(new InferenceSelectFunction<Harness.KafkaRecord,
Tuple7<String, String, Date, String, String, Double, Double>>() {...};
((SingleOutputStreamOperator) LCxAccResult).slotSharingGroup("...");
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#L99
[2]
https://ci.apache.org/projects/flink/flink-docs-release-1.3/api/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.html#returns-org.apache.flink.api.common.typeinfo.TypeInformation-
2017-10-26 16:31 GMT+08:00 AndreaKinn <kinn6...@hotmail.it>:
> Sorry Tony it is my fault, I was wrong the first post. Actually now my
> situation is the following:
>
>
> DataStream<Tuple7<String, String, Date, String, String, Double, Double>>
> LCxAccResult = HTM.learn(LCxAccStream, new Harness.AnomalyNetwork())
> .select(new InferenceSelectFunction<
> Harness.KafkaRecord,
> Tuple7<String, String, Date, String, String, Double, Double>>() {...}
>
>
> so actually the return value of "Learn" is a HTMStream object and the
> return
> value of "Select" is a DataStream where I need to implement
> slotSharingGroup
> on Learn. So I think I can't set SingleOutputStreamOperator as return value
> of learn, I believe (I hope not since I have not a clue how to do it :D) I
> need to define slotSharingGroup directly in HTMStream class, as in the
> first
> post.
>
>
>
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.
> n4.nabble.com/
>
