Reuven Lax created BEAM-3979: -------------------------------- Summary: New DoFn should allow injecting of all parameters in ProcessContext Key: BEAM-3979 URL: https://issues.apache.org/jira/browse/BEAM-3979 Project: Beam Issue Type: Bug Components: sdk-java-core Affects Versions: 2.4.0 Reporter: Reuven Lax Assignee: Reuven Lax Fix For: 2.5.0
This was intended in the past, but never completed. Ideally all primitive parameters in ProcessContext should be injectable, and OutputReceiver parameters can be used to collection output. So, we should be able to write a DoFn as follows @ProcessElement public void process(@Element String word, OutputReceiver<String> receiver) { receiver.output(word.toUpperCase()); } -- This message was sent by Atlassian JIRA (v7.6.3#76005)