Skip to content

Commit

Permalink
Fix typo in side-inputs (apache#30817)
Browse files Browse the repository at this point in the history
  • Loading branch information
shahar1 authored Apr 1, 2024
1 parent db33805 commit a520b95
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ func init() {
```
# Side inputs are available as extra arguments in the DoFn's process method or Map / FlatMap's callable.
# Optional, positional, and keyword arguments are all supported. Deferred arguments are unwrapped into their
# actual values. For example, using pvalue.AsIteor(pcoll) at pipeline construction time results in an iterable
# actual values. For example, using pvalue.AsIter(pcoll) at pipeline construction time results in an iterable
# of the actual elements of pcoll being passed into each process invocation. In this example, side inputs are
# passed to a FlatMap transform as extra arguments and consumed by filter_using_length.
words = ...
Expand Down Expand Up @@ -289,4 +289,4 @@ def join_fn(persons, cities_to_time):
'name': person['name'],
'city
```
{{end}}
{{end}}

0 comments on commit a520b95

Please sign in to comment.