it would look more like:
for (Tuple2<> t2 : parse(t.f3) {
collector.collect(t2);
}
Michael
> On Apr 27, 2018, at 9:08 AM, Soheil Pourbafrani <soheil.i...@gmail.com> wrote:
>
> Hi, I want to use flatMap to pass to function namely 'parse' a tuple and it
> will return multiple tuple, that each should be a record in datastream object.
>
> Something like this:
>
> DataStream<Tuple2<Integer,Long>> res = stream.flatMap(new
> FlatMapFunction<tuple3<int, int, int>, Tuple2<Integer,Long>>() {
>
> @Override
> public void flatMap(Tuple3<int, int, int> t,
> Collector<Tuple2<Integer,Long>> collector) throws Exception {
>
> collector.collect(parse(t.f_3));
> }
> });
>
> that parse will return for example 6 tuples2 and I want them inserted into
> res datastream.
