File tree 1 file changed +5
-1
lines changed
sdks/python/apache_beam/yaml
1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -544,6 +544,7 @@ class _Explode(beam.PTransform):
544
544
`cross_product` is set to `true` but only the two rows
545
545
`('a', 1)` and `('b', 2)` when it is set to `false`.
546
546
Only meaningful (and required) if multiple rows are specified.
547
+ error_handling: Whether and how to handle errors during iteration.
547
548
""" # pylint: disable=line-too-long
548
549
549
550
def __init__ (
@@ -563,7 +564,10 @@ def __init__(
563
564
cross_product = True
564
565
self ._fields = fields
565
566
self ._cross_product = cross_product
566
- # TODO(yaml): Support standard error handling argument.
567
+ # TODO(yaml):
568
+ # 1. Support standard error handling argument.
569
+ # 2. Supposedly error_handling parameter is not an accepted parameter when
570
+ # executing. Needs further investigation.
567
571
self ._exception_handling_args = exception_handling_args (error_handling )
568
572
569
573
@maybe_with_exception_handling
You can’t perform that action at this time.
0 commit comments