flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Telco Phone <tel...@yahoo.com>
Subject access to key in sink
Date Sat, 24 Dec 2016 16:12:05 GMT
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