You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2020/08/26 09:08:02 UTC

[GitHub] [flink] wulei0302 commented on a change in pull request #13135: [FLINK-18797][docs][examples] Update deprecated forms of keyBy in docs and examples

wulei0302 commented on a change in pull request #13135:
URL: https://github.com/apache/flink/pull/13135#discussion_r477150966



##########
File path: docs/dev/stream/operators/index.md
##########
@@ -104,8 +104,8 @@ dataStream.filter(new FilterFunction<Integer>() {
             <p>
             This transformation returns a <em>KeyedStream</em>, which is, among other things, required to use <a href="{{ site.baseurl }}/dev/stream/state/state.html#keyed-state">keyed state</a>. </p>
 {% highlight java %}
-dataStream.keyBy("someKey") // Key by field "someKey"
-dataStream.keyBy(0) // Key by the first element of a Tuple
+dataStream.keyBy(value -> value.someKey) // Key by field "someKey", or maybe use getSomeKey

Review comment:
       @dawidwys  Thank you very much for your review. I am very happy for your good suggestions.  Please help me review it again.  thank you.




----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org