Resurrecting a thread from the users list of the same name. I hacked
together an example of what this code could look like. I created a modified
MapElements
<https://github.com/eljefe6a/beamexample/blob/master/DataflowTutorial/src/main/java/com/google/cloud/dataflow/examples/complete/game/utils/MapContextElements.java>
class to pass in the ProcessContext and BoundedWindow.

Here is what the resulting client code looked like
<https://github.com/eljefe6a/beamexample/blob/master/DataflowTutorial/src/main/java/com/google/cloud/dataflow/examples/complete/game/utils/Output.java#L96>
.

I wanted to prototype something to if this code is something others want to
do. I think this sort of functionality needs to be accessible via Lambdas.

I'm not happy that all of the objects are being passed in as a single
object. Now that the new DoFN splits the two objects, I had to include both.

Does anyone else see value in improving this idea before I spend more time
cleaning things up?

Thanks,

Jesse

Reply via email to