<?xml version="1.0" encoding="UTF-8"?>
<rss xmlns:content="http://purl.org/rss/1.0/modules/content/" xmlns:dc="http://purl.org/dc/elements/1.1/" xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#" xmlns:taxo="http://purl.org/rss/1.0/modules/taxonomy/" version="2.0">
  <channel>
    <title>topic GroupBy in a multi node environment in Data Engineering</title>
    <link>https://community.databricks.com/t5/data-engineering/groupby-in-a-multi-node-environment/m-p/16968#M11053</link>
    <description>&lt;P&gt;&lt;/P&gt;
&lt;P&gt;I have a group of rows with Information on a nested product calls. &lt;/P&gt;&lt;P&gt;&lt;/P&gt;example-
&lt;P&gt;Trxn1-product1-caller1-local1&lt;/P&gt;
&lt;P&gt;Trxn1-Product1-local1-local2&lt;/P&gt;
&lt;P&gt;Trxn1-Product1-local2-local3&lt;/P&gt;
&lt;P&gt;here’s is a expected calls for a product &lt;/P&gt;
&lt;P&gt;product1-caller1-local1&lt;/P&gt;
&lt;P&gt;Product1-local1-local2&lt;/P&gt;
&lt;P&gt;Product1-local2-local3&lt;/P&gt;
&lt;P&gt;Product1-local3-local4&lt;/P&gt;
&lt;P&gt;Product1-local4-local5&lt;/P&gt;
&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;now I need to create one additional record to my dataframe 
&lt;P&gt;Trxn1-product1-local3-local4. Picking only this coz, that’s the first missing link in the chain based on where it failed. &lt;/P&gt;&lt;P&gt;&lt;/P&gt;
&lt;P&gt;Like Trxn1, I have 10000s of them and I need to group these by transaction Id and apply the condition based on the product. &lt;/P&gt;&lt;P&gt;&lt;/P&gt;
&lt;P&gt;Trying if for loop is taking a &lt;/P&gt; 
&lt;P&gt;&lt;/P&gt;</description>
    <pubDate>Sat, 31 Jul 2021 21:48:02 GMT</pubDate>
    <dc:creator>RajuNagarajan</dc:creator>
    <dc:date>2021-07-31T21:48:02Z</dc:date>
    <item>
      <title>GroupBy in a multi node environment</title>
      <link>https://community.databricks.com/t5/data-engineering/groupby-in-a-multi-node-environment/m-p/16968#M11053</link>
      <description>&lt;P&gt;&lt;/P&gt;
&lt;P&gt;I have a group of rows with Information on a nested product calls. &lt;/P&gt;&lt;P&gt;&lt;/P&gt;example-
&lt;P&gt;Trxn1-product1-caller1-local1&lt;/P&gt;
&lt;P&gt;Trxn1-Product1-local1-local2&lt;/P&gt;
&lt;P&gt;Trxn1-Product1-local2-local3&lt;/P&gt;
&lt;P&gt;here’s is a expected calls for a product &lt;/P&gt;
&lt;P&gt;product1-caller1-local1&lt;/P&gt;
&lt;P&gt;Product1-local1-local2&lt;/P&gt;
&lt;P&gt;Product1-local2-local3&lt;/P&gt;
&lt;P&gt;Product1-local3-local4&lt;/P&gt;
&lt;P&gt;Product1-local4-local5&lt;/P&gt;
&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;now I need to create one additional record to my dataframe 
&lt;P&gt;Trxn1-product1-local3-local4. Picking only this coz, that’s the first missing link in the chain based on where it failed. &lt;/P&gt;&lt;P&gt;&lt;/P&gt;
&lt;P&gt;Like Trxn1, I have 10000s of them and I need to group these by transaction Id and apply the condition based on the product. &lt;/P&gt;&lt;P&gt;&lt;/P&gt;
&lt;P&gt;Trying if for loop is taking a &lt;/P&gt; 
&lt;P&gt;&lt;/P&gt;</description>
      <pubDate>Sat, 31 Jul 2021 21:48:02 GMT</pubDate>
      <guid>https://community.databricks.com/t5/data-engineering/groupby-in-a-multi-node-environment/m-p/16968#M11053</guid>
      <dc:creator>RajuNagarajan</dc:creator>
      <dc:date>2021-07-31T21:48:02Z</dc:date>
    </item>
  </channel>
</rss>

