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 <rmetz...@apache.org> wrote: > 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 <the.swapni...@gmail.com> > wrote: > >> Hi Team, >> >> Is there support for Distributed Cache in StreamExecutionEnvironment? I >> didn't find any such things in StreamExecutionEnvironment. I am using flink >> 1.1.1 >> I found distributed cache for ExecutionEnvironment but not for >> StreamExecutionEnvironment >> >> If Yes, Can anybody tell me how to use same ? Else any work around is >> there for same ? >> >> Regards, >> Swapnil >> > >
