access to key in sink

[Telco Phone]

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");