[FLINK-13065][datastream][docs] Clarify key selector example

spotify · Oct 4, 2019 · 28c5264 · 28c5264
1 parent 3f495d8
commit 28c5264
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/docs/dev/stream/state/broadcast_state.md b/docs/dev/stream/state/broadcast_state.md
@@ -52,9 +52,9 @@ Starting from the stream of `Items`, we just need to *key it* by `Color`, as we
 make sure that elements of the same color end up on the same physical machine.
 
 {% highlight java %}
-// key the shapes by color
-KeyedStream<Item, Color> colorPartitionedStream = shapeStream
- .keyBy(new KeySelector<Shape, Color>(){...});
+// key the items by color
+KeyedStream<Item, Color> colorPartitionedStream = itemStream
+ .keyBy(new KeySelector<Item, Color>(){...});
 {% endhighlight %}
 
 Moving on to the `Rules`, the stream containing them should be broadcasted to all downstream tasks, and these tasks 

diff --git a/docs/dev/stream/state/broadcast_state.zh.md b/docs/dev/stream/state/broadcast_state.zh.md
@@ -52,9 +52,9 @@ Starting from the stream of `Items`, we just need to *key it* by `Color`, as we
 make sure that elements of the same color end up on the same physical machine.
 
 {% highlight java %}
-// key the shapes by color
-KeyedStream<Item, Color> colorPartitionedStream = shapeStream
- .keyBy(new KeySelector<Shape, Color>(){...});
+// key the items by color
+KeyedStream<Item, Color> colorPartitionedStream = itemStream
+ .keyBy(new KeySelector<Item, Color>(){...});
 {% endhighlight %}
 
 Moving on to the `Rules`, the stream containing them should be broadcasted to all downstream tasks, and these tasks