[ https://issues.apache.org/jira/browse/BEAM-3979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Reuven Lax resolved BEAM-3979. ------------------------------ Resolution: Fixed > 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 > Priority: Major > Fix For: 2.5.0 > > Time Spent: 5h 20m > Remaining Estimate: 0h > > 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)