flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jark Wu" <wuchong...@alibaba-inc.com>
Subject Re: access to key in sink
Date Tue, 10 Jan 2017 04:51:39 GMT
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 <telco5@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");

View raw message