Re: access to key in sink

[Jark Wu]

Hi Telco,

What do you mean about the “keyBy value” ?  Is it the string parameter value, 
i.e. “partition” in your case , or the real key value of an actual element 
being processed ? 

If you mean the string parameter value, it seems that currently it doesn’t 
support. If you mean the latter one, Aljoscha has pointed out.

- Jark Wu 

> 在 2016年12月25日，上午12:12，Telco Phone <tel...@yahoo.com> 写道：
> 
> 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");