flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Abdul Salam Shaikh <abd.salam.sha...@gmail.com>
Subject Regarding dividing the streams using keyby
Date Mon, 21 Nov 2016 01:07:19 GMT
I am trying to creating a keyed stream which collects events in a window
using :

 DataStream<Tuple4<String, String, String, Long>> windowedStream =
                jsonToTuple.keyBy(0)
                            .window(GlobalWindows.create())
                            .trigger(new WindowCustomTrigger())
                            .apply(new WindowCrossingCalculator());

Is it possible to further create a keyed stream from this already created
keyedStream using some other field for the keyBy function ?

-- 
Thanks & Regards,

*Abdul Salam Shaikh*

Mime
View raw message