Hi,
I’m working on a task BEAM-3280 (Add typehints with TaggedOutput) and just want
to clarify before I send a PR.
https://issues.apache.org/jira/browse/BEAM-3280
<https://issues.apache.org/jira/browse/BEAM-3280>
Is it sufficient to modify the code in
apache_beam.cookbook.multiple_output_pardo.py like below ?
# with_outputs allows accessing the explicitly tagged outputs of a DoFn.
split_lines_result = (lines
|
beam.ParDo(SplitLinesToWordsFn().with_output_types(
beam.typehints.Tuple[
beam.typehints.Generator[unicode],
beam.typehints.Generator[unicode],
beam.typehints.Generator[int],
],
)).with_outputs(
SplitLinesToWordsFn.OUTPUT_TAG_SHORT_WORDS,
SplitLinesToWordsFn.OUTPUT_TAG_CHARACTER_COUNT,
main='words')
)
Or do you expect something different to add a typehint to multiple outputs?
Regards,
Norio Akagi