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)
