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 >
