You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Reuven Lax (JIRA)" <ji...@apache.org> on 2019/03/19 00:47:00 UTC

[jira] [Created] (BEAM-6858) Support side inputs injected into a DoFn

Reuven Lax created BEAM-6858:
--------------------------------

             Summary: Support side inputs injected into a DoFn
                 Key: BEAM-6858
                 URL: https://issues.apache.org/jira/browse/BEAM-6858
             Project: Beam
          Issue Type: Bug
          Components: sdk-java-core
            Reporter: Reuven Lax


Beam currently supports injecting main inputs into a DoFn process method. A user can write the following:

@ProcessElement public void process(@Element InputT element)

And Beam will (using ByteBuddy code generation) inject the input element into the process method.

We would like to also support the same for side inputs. For example:

@ProcessElement public void process(@Element InputT element, @SideInput("tag1") String input1, @SideInput("tag2") Integer input2) 

This requires the existing process-method analysis framework to capture these side inputs. The ParDo code would have to verify the type of the side input and include them in the list of side inputs. This would also eliminate the need for the user to explicitly call withSideInputs on the ParDo.

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)