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] [Updated] (FLINK-13065) Document example snippet correction
using KeySelector
[ https://issues.apache.org/jira/browse/FLINK-13065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Mans Singh updated FLINK-13065:
-------------------------------
Description:
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>.
was:
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>.
> 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
> Priority: Minor
> Labels: correction, doc,, example
>
> 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
(v7.6.3#76005)