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

Training figure program_dataflow.svg should use preferred parts of the API

    XMLWordPrintableJSON

Details

    Description

      It would be better if fig/program_dataflow.svg used a ProcessWindowFunction, rather than a WindowFunction.

      It also uses a BucketingSink, which sets a bad example. 

      Note that this is not a trivial edit, since it doesn't work to simply replace new BucketingSink with new StreamingFileSink. Something like this would be better:

       
      final StreamingFileSink<GenericRecord> sink = StreamingFileSink
              .forBulkFormat(...)
              .build();

      stats.addSink(sink);

      Note: This figure is only used once, in the Training Overview page.

      Attachments

        Activity

          People

            Unassigned Unassigned
            alpinegizmo David Anderson
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: