You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Mans Singh (JIRA)" <ji...@apache.org> on 2019/07/02 22:32:00 UTC

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

Mans Singh created FLINK-13065:
----------------------------------

             Summary: Document example snippet correction using KeySelector
                 Key: FLINK-13065
                 URL: https://issues.apache.org/jira/browse/FLINK-13065
             Project: Flink
          Issue Type: Improvement
          Components: Documentation
            Reporter: Mans Singh
            Assignee: Mans Singh


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}
 

How it uses shape stream and use KeySelector<Shape,Color> but should use KeySelector<Item,Color> to create KeyedStream<Item,Color>.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)