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

Reply via email to