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 <tel...@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");
>
>
