Apache Beam: Difference between revisions

 
Line 11: Line 11:
Pardo allows you to pass in a function and generate multiple items.<br>
Pardo allows you to pass in a function and generate multiple items.<br>
If you are yielding many items though, you should do a <code>beam.Reshuffle()</code> afterwards to split and get more parallelism.
If you are yielding many items though, you should do a <code>beam.Reshuffle()</code> afterwards to split and get more parallelism.
===GroupByKey===


==Administration==
==Administration==