<?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>question Re: How to get the non group by columns in spark structured streaming in Support Questions</title>
    <link>https://community.cloudera.com/t5/Support-Questions/How-to-get-the-non-group-by-columns-in-spark-structured/m-p/200512#M162533</link>
    <description>&lt;P&gt;&lt;A rel="user" href="https://community.cloudera.com/users/24259/elangork.html" nodeid="24259"&gt;@elango vaithiyanathan&lt;/A&gt;
&lt;/P&gt;&lt;P&gt;Apply &lt;STRONG&gt;Aggregate(agg)&lt;/STRONG&gt; function after group by&lt;/P&gt;&lt;PRE&gt;val grpbyDF = updatedDf.groupBy("ROW_ID","ODS_WII_VERB").agg(max("STG_LOAD_TS"))&lt;/PRE&gt;&lt;P&gt;Now the &lt;STRONG&gt;grpbyDF&lt;/STRONG&gt; dataframe is going to group by &lt;STRONG&gt;ROW_ID,ODS_WII_VERB&lt;/STRONG&gt; and gets max value of &lt;STRONG&gt;STG_LOAD_TS&lt;/STRONG&gt; column.&lt;/P&gt;</description>
    <pubDate>Sat, 03 Feb 2018 22:47:43 GMT</pubDate>
    <dc:creator>Shu_ashu</dc:creator>
    <dc:date>2018-02-03T22:47:43Z</dc:date>
  </channel>
</rss>

