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

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

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    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

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            Unassigned Unassigned
            alpinegizmo David Anderson

            Dates

              Created:
              Updated:

              Slack

                Issue deployment