[GitHub] [beam] damccorm opened a new issue, #17928: Add support for side inputs/outputs to Java 8 lambdas in MapElements

[GitBox <gi...@apache.org>]

damccorm opened a new issue, #17928:
URL: https://github.com/apache/beam/issues/17928

   Currently there's no way to use side inputs or outputs within Java 8 lambdas and MapElements.  It would be nice if you could do something like this:
   
   ```
   
   PCollection<Integer> wordLengths = words.apply(
       MapElements.via((String word) -> {
         int sideInput1=
   [[[ GetSideInputHere(); ]]]
         [[[ SetSideOutputHere ]]] (sideInput1+word.length());
         return
   word.length();
       }).withOutputType(new TypeDescriptor<Integer>() {});
   
   ```
   
   
   Imported from Jira [BEAM-656](https://issues.apache.org/jira/browse/BEAM-656). Original Jira may contain additional context.
   Reported by: jpatokal.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [beam] damccorm closed issue #17928: Add support for side inputs/outputs to Java 8 lambdas in MapElements

[GitBox <gi...@apache.org>]

damccorm closed issue #17928: Add support for side inputs/outputs to Java 8 lambdas in MapElements
URL: https://github.com/apache/beam/issues/17928


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org