flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tony Wei <tony19920...@gmail.com>
Subject Re: StreamTransformation<T> object
Date Thu, 26 Oct 2017 08:49:37 GMT
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 <kinn6aer@hotmail.it>:

> Sorry Tony it is my fault, I was wrong the first post. Actually now my
> situation is the following:
>
>
> DataStream<Tuple7&lt;String, String, Date, String, String, Double, Double>>
> LCxAccResult = HTM.learn(LCxAccStream, new Harness.AnomalyNetwork())
>                                 .select(new InferenceSelectFunction<
> Harness.KafkaRecord,
> Tuple7&lt;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/
>

Mime
View raw message