Jani Patokallio created BEAM-656: ------------------------------------ Summary: Add support for side inputs/outputs to Java 8 lambdas in MapElements 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 (v6.3.4#6332)