[jira] [Updated] (FLINK-13065) Document example snippet correction using KeySelector

["Chesnay Schepler (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-13065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chesnay Schepler updated FLINK-13065:
-------------------------------------
    Component/s: API / DataStream

> Document example snippet correction using KeySelector
> -----------------------------------------------------
>
>                 Key: FLINK-13065
>                 URL: https://issues.apache.org/jira/browse/FLINK-13065
>             Project: Flink
>          Issue Type: Improvement
>          Components: API / DataStream, Documentation
>            Reporter: Mans Singh
>            Assignee: Mans Singh
>            Priority: Minor
>              Labels: correction, doc,, example, pull-request-available
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> The broadcast state [example|[https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/stream/state/broadcast_state.html#provided-apis]] states:
>  
> {noformat}
> Starting from the stream of Items, we just need to key it by Color, as we want pairs of the same color. This will make sure that elements of the same color end up on the same physical machine.
> // key the shapes by color
> KeyedStream<Item, Color> colorPartitionedStream = shapeStream
>                         .keyBy(new KeySelector<Shape, Color>(){...});{noformat}
>  
> However, it uses shape stream and KeySelector<Shape,Color> but should use KeySelector<Item,Color> to create KeyedStream<Item,Color>.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)