Yes. Here: https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/index.html#example-program
On Thu, May 5, 2016 at 1:16 PM, Piyush Shrivastava <piyush...@yahoo.co.in> wrote: > Hi Robert, > > Can you share an example where flatmap is used to access elements? > > Thanks and Regards, > Piyush Shrivastava <piy...@webograffiti.com> > [image: WeboGraffiti] > http://webograffiti.com > > > On Thursday, 5 May 2016 4:45 PM, Robert Metzger <rmetz...@apache.org> > wrote: > > > Hi, > > you can just use a flatMap() on a DataStream to access individual elements > from a stream. > > On Thu, May 5, 2016 at 1:00 PM, Piyush Shrivastava <piyush...@yahoo.co.in> > wrote: > > Hi all, > > Can we access individual elements from a DataStream through an iterator > like we can in a WindowedStream with the apply function? > > I am able to access the elements of a WindowedStream using the apply > function and using the Iterable and Collector interfaces: > > val ds = ws.apply((K, W, input: Iterable[T], output: Collector[R]) => { > val it = input.toIterator > while(it.hasNext){ > ... > } > }) > > the output of this function is a DataStream. I want to perform a keyBy on > this DataStream and then again iterate through it's individual elements. We > cannot use the apply function on DataStreams like in WindowedStreams. Is > there any other way? > > Thanks and Regards, > Piyush Shrivastava <piy...@webograffiti.com> > [image: WeboGraffiti] > http://webograffiti.com > > > > >
