Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-3645 Support multi-process execution on the FnApiRunner
  3. BEAM-7580

Split GroupingBuffer to N pieces

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • None
    • 2.15.0
    • sdk-py-core
    • None

    Description

      Split GroupingBuffer into N pieces and reduce data size a worker needs to process to improve performance. 

      Attachments

        Activity

          People

            hannahjiang Hannah Jiang
            hannahjiang Hannah Jiang
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: