Can we transfrom PCollection to ArrayList?

[linrick]

Hi all,

I am Rick

I would like to transform datatype from PCollection to ArrayList, and I am not 
sure if it is right?

My run env is following Java: 1.8 and Beam: 2.1.0

My java code is as:
ArrayList<Integer> myList = new ArrayList<Integer>();

PipelineOptions options = PipelineOptionsFactory.create();
Pipeline p = Pipeline.create(options);
PCollection<Integer> data=p.apply("data",Create.of(1,2,3,4,5));
PCollection<Integer> newdata=data.apply(ParDo.of(new DoFn<Integer,Integer>() {
@ProcessElement
    public void processElement(ProcessContext c)
    {
        int datavalue=c.element()+1;
        System.out.println("data="+datavalue);
       c.output(datavalue);
}
}));

p.run();

If any idea could be shared with me, I highly appreciate it.

Thanks

Rick


--
本信件可能包含工研院機密資訊，非指定之收件者，請勿使用或揭露本信件內容，並請銷毀此信件。 This email may contain 
confidential information. Please do not use or disclose it in any way and 
delete it if you are not the intended recipient.