[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
]
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 colorPartitionedStream = shapeStream
> .keyBy(new KeySelector Color>(){...});{noformat}
>
> However, it uses shape stream and KeySelector but should use
> KeySelector to create KeyedStream.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[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
]
ASF GitHub Bot updated FLINK-13065:
---
Labels: correction doc, example pull-request-available (was: correction
doc, example)
> 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, pull-request-available
>
> 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 colorPartitionedStream = shapeStream
> .keyBy(new KeySelector Color>(){...});{noformat}
>
> However, it uses shape stream and KeySelector but should use
> KeySelector to create KeyedStream.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
[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 colorPartitionedStream = shapeStream
.keyBy(new KeySelector(){...});{noformat}
However, it uses shape stream and KeySelector but should use
KeySelector to create KeyedStream.
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 colorPartitionedStream = shapeStream
.keyBy(new KeySelector(){...});{noformat}
How it uses shape stream and use KeySelector but should use
KeySelector to create KeyedStream.
> 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 colorPartitionedStream = shapeStream
> .keyBy(new KeySelector Color>(){...});{noformat}
>
> However, it uses shape stream and KeySelector but should use
> KeySelector to create KeyedStream.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
