Hello,
I have created a java class which extends DoFn<>, there are
list of objects of type ABC (List<ABC>) populated in
processElement(ProcessContext c) at runtime and would like to generate
respective PCollection<ABC> from List<ABC> so that the subsequent
transformation can do parallel execution on each ABC object in
PCollection<ABC>. How do we create PCollection from in-memory object created in
DoFn<>? OR How do we get pipeline object being in DoFn<>? OR is there any SDK
guidelines to refer?
Thanks,
S. Sahayaraj
