Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[BEAM-9650] Cleanup documentation on side inputs patterns #11415

Merged
merged 5 commits into from
Apr 17, 2020
Merged

[BEAM-9650] Cleanup documentation on side inputs patterns #11415

Changes from 1 commit
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
232357e
Cleanup documentation
Apr 14, 2020
96814cb
Address comments
Apr 14, 2020
c931ba9
Rephrase
Apr 15, 2020
a914d7c
one more rephrasing
Apr 15, 2020
297d630
One more comment
Apr 17, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
One more comment
  • Loading branch information
Mikhail Gryzykhin committed Apr 17, 2020
commit 297d6304cfe805b26e017dcf3f16255b048b658b
2 changes: 1 addition & 1 deletion website/src/documentation/patterns/side-inputs.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ No sample present.
## Slowly updating side input using windowing

You can read side input data periodically into distinct PCollection windows.
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

In Beam, we have IO.Read transforms that do read source data. Later data read can be assigned to specific window.

Later, when you apply the side input to your main input, each main input
When you apply the side input to your main input, each main input
window is automatically matched to a single side input window.
This guarantees consistency on the duration of the single window,
meaning that each window on the main input will be matched to a single
Expand Down