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)
