Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
2.4.0
Description
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()); }