You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by "Reuven Lax (JIRA)" <ji...@apache.org> on 2018/04/02 03:11:00 UTC

[jira] [Created] (BEAM-3979) New DoFn should allow injecting of all parameters in ProcessContext

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)