flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: access to key in sink
Date Mon, 09 Jan 2017 14:42:34 GMT
Hi,
it's not possible to access the key in the open method because without an
element that is being processed there is no key. The user function is being
used to produce elements of different keys that are being processed on the
same shard (instance of a parallel operator). You can get the key manually
by inspecting the element in the invoke() method of your sink.

Cheers,
Aljoscha

On Sat, 24 Dec 2016 at 17:15 Telco Phone <telco5@yahoo.com> wrote:

> I am trying to access the keyBy value in the "open" method in a RichSink
>
>
> Is there a way to access the actual keyBy value in the RichSink ?
>
>
>
> DataStream<TestRecord> stream =
>         env.addSource(new FlinkKafkaConsumer08<>("test", schema, properties)
>         ).setParallelism(1).keyBy("partition");
>
>

Mime
View raw message