Hi Connell,
To unsubscribe, you should send a message to
user-unsubscr...@beam.apache.org and/or dev-unsubscr...@beam.apache.org
Thanks,
Valentyn
On Thu, Apr 21, 2022 at 5:39 PM Connell O'Callaghan
wrote:
> unsubscribe
>
>
In this case, if you already know that the size of your result is quite small
and fits into memory than you need to have to materialise your results on one
worker in the same JVM. You can do that with assigning the same key for all
result elements and then apply GroupByKey transform over this
Hi Alexey,
I have a small result of Pcollection from SQLTransform. I have to pass
this result to a mailing class that sends mail, with body as values from
Pcollection, In a tabular format. The number of elements in
Pcollection will be less than 10 always.
Regards,
Kayal
>
> On Apr 21, 2022,
Hi Kayal,
In general, PCollection is infinite collection of elements. So, there is no
only one simple way to do what you are asking and the solution will depend on a
case where it’s needed.
Could you give an example why and where in your pipeline you do need this?
—
Alexey
> On 21 Apr 2022,
