You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Monika Kovacs (Jira)" <ji...@apache.org> on 2019/12/30 20:00:00 UTC
[jira] [Comment Edited] (BEAM-7468) Add Python global window side
input pattern
[ https://issues.apache.org/jira/browse/BEAM-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17005796#comment-17005796 ]
Monika Kovacs edited comment on BEAM-7468 at 12/30/19 7:59 PM:
---------------------------------------------------------------
h4. 7.3.4. Single global window
If your {{PCollection}} is bounded (the size is fixed), you can assign all the elements to a single global window. The following example code shows how to set a single global window for a {{PCollection}}:
{quote}{{from apache_beam import windowsession_windowed_items = (items | 'window' >> beam.WindowInto(window.GlobalWindows()))}}
{quote}
was (Author: monika101):
h4. 7.3.4. Single global window
If your {{PCollection}} is bounded (the size is fixed), you can assign all the elements to a single global window. The following example code shows how to set a single global window for a {{PCollection}}:
{{from apache_beam import windowsession_windowed_items = (items | 'window' >> beam.WindowInto(window.GlobalWindows()))}}
> Add Python global window side input pattern
> -------------------------------------------
>
> Key: BEAM-7468
> URL: https://issues.apache.org/jira/browse/BEAM-7468
> Project: Beam
> Issue Type: Improvement
> Components: website
> Reporter: Cyrus Maden
> Assignee: Reza ardeshir rokni
> Priority: Minor
>
> Tracker for documenting a Python version of the side input pattern "Using global window side inputs in non-global windows"
> [https://beam.apache.org|https://beam.apache.org/documentation/pipelines/design-your-pipeline/] [/documentation/patterns/side-input-patterns/#using-global-window-side-inputs-in-non-global-windows|http://localhost:4000/documentation/patterns/side-input-patterns/]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)