Re: Distributed Cache support for StreamExecutionEnvironment

2016-09-11 Thread Swapnil Chougule
Thanks Robert. It worked for me. I have used RichFunction's open() method. Regards, Swapnil On Fri, Sep 9, 2016 at 3:40 PM, Robert Metzger wrote: > Hi Swapnil, > > there's no support for something like DistributedCache in the DataStream > API. > However, as a workaround, you can rely on the Ric

Re: Distributed Cache support for StreamExecutionEnvironment

2016-09-09 Thread Robert Metzger
Hi Swapnil, there's no support for something like DistributedCache in the DataStream API. However, as a workaround, you can rely on the RichFunction's open() method's to load such data directly from a distributed file system. Regards, Robert On Fri, Sep 9, 2016 at 8:13 AM, Swapnil Chougule wrot