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
wrote:
> Hi Robert,
>
> Can you share an example where flatmap is used to access elements?
>
> Thanks and Regards,
> Piyush Shrivastava
Hi Robert,
Can you share an example where flatmap is used to access elements?
Thanks and Regards,Piyush Shrivastava
http://webograffiti.com
On Thursday, 5 May 2016 4:45 PM, Robert Metzger wrote:
Hi,
you can just use a flatMap() on a DataStream to access individual elements from
a stre
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
wrote:
> Hi all,
>
> Can we access individual elements from a DataStream through an iterator
> like we can in a WindowedStream with the apply function
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: I
