You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Swapnil Chougule <th...@gmail.com> on 2016/09/09 06:13:34 UTC

Distributed Cache support for StreamExecutionEnvironment

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

Re: Distributed Cache support for StreamExecutionEnvironment

Posted by Swapnil Chougule <th...@gmail.com>.

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 <rm...@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 <th...@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
>>
>
>

Re: Distributed Cache support for StreamExecutionEnvironment

Posted by Robert Metzger <rm...@apache.org>.

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 <th...@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
>