Jani Patokallio created BEAM-656:

             Summary: Add support for side inputs/outputs to Java 8 lambdas in 
                 Key: BEAM-656
                 URL: https://issues.apache.org/jira/browse/BEAM-656
             Project: Beam
          Issue Type: Improvement
          Components: sdk-ideas
         Environment: Java 8
            Reporter: Jani Patokallio
            Assignee: James Malone
            Priority: Minor

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>() {});

This message was sent by Atlassian JIRA

Reply via email to