title: distributing collect_list function across worker nodes
body: <p>I am performing an aggregated array collection using the following code in pyspark:</p>
  <pre><code>df1=df.groupBy('key').agg(collect_list('value'))
  </code></pre>
  <p>I know functions like collect forces data into a single node. Is it possible to achieve the same result while at the same time leveraging the power of distributed cloud computing?</p>