flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ufuk Celebi <...@apache.org>
Subject Re: Broadcast Config-Values through connected Configuration Stream
Date Wed, 26 Oct 2016 14:09:32 GMT
Does the following work?

stream1.keyBy().connect(stream2.broadcast())

On Wed, Oct 26, 2016 at 2:01 PM, Julian Bauß <julian.bauss@gmail.com> wrote:
> Hello Everybody,
>
> I'm currently trying to change the state of a CoFlatMapFunction with the
> help of a connected configuration-stream. The code looks something like
> this.
>
> streamToBeConfigured.connect(configMessageStream)
> .keyBy(new SomeIdKeySelecor(), new ConfigMessageKeySelector)
> .flatMap(new FunctionWithConfigurableState())
> .addSink(...);
>
> The Stream with the actual functionality is keyedBy an Id but the
> ConfigMessages don't contain any Id to key them by. They are just
> "key=value"-Strings that should be broadcasted to all instances of the
> CoFlatMapFunction() regardless of what Id they are keyed by.
>
> Is there any way to do that?
>
> Best Regards,
>
> Julian

Mime
View raw message