[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Create PCollection<ABC> from List<ABC>in DoFn<>


                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?




S. Sahayaraj