Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-13065

Document example snippet correction using KeySelector

    XMLWordPrintableJSON

    Details

      Description

      The broadcast state example states:

       

      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>(){...});

       

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

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                mans2singh Mans Singh
                Reporter:
                mans2singh Mans Singh
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m