Is there a way to get the PCollection's results in the executing process?
In Spark this is using the collect method on an RDD.

This would be for small amounts of data stored in a PCollection like:

PCollection<Long> count = partition.apply(Count.globally());
System.out.println(valuesincount);

Thanks,

Jesse

Reply via email to