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)
