<?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: Pig Accumulator in Spark in Archives of Support Questions (Read Only)</title>
    <link>https://community.cloudera.com/t5/Archives-of-Support-Questions/Pig-Accumulator-in-Spark/m-p/130819#M31363</link>
    <description>&lt;P&gt;I'm not aware of the concept of Spark's Accumulators exposed as "first-class" objects in Pig and have always advised that you would need to build a UDF for such activities if you couldn't simply get away with filtering the things to count (such as "good" records and "rejects") into separate aliases then count them up.  &lt;/P&gt;&lt;P&gt;Here is a blog post going down the UDF path; &lt;A href="https://dzone.com/articles/counters-apache-pig" target="_blank"&gt;https://dzone.com/articles/counters-apache-pig&lt;/A&gt;.  &lt;/P&gt;&lt;P&gt;Good luck &amp;amp; I'd love to hear if there was something I've been missing all along directly from Pig.&lt;/P&gt;</description>
    <pubDate>Fri, 10 Jun 2016 21:41:22 GMT</pubDate>
    <dc:creator>LesterMartin</dc:creator>
    <dc:date>2016-06-10T21:41:22Z</dc:date>
    <item>
      <title>Pig Accumulator in Spark</title>
      <link>https://community.cloudera.com/t5/Archives-of-Support-Questions/Pig-Accumulator-in-Spark/m-p/130818#M31362</link>
      <description>&lt;P&gt;are there functions out there that utilize something like the accumulator interface in Pig where the data doesn't have to stay in memory?&lt;/P&gt;</description>
      <pubDate>Thu, 09 Jun 2016 22:26:09 GMT</pubDate>
      <guid>https://community.cloudera.com/t5/Archives-of-Support-Questions/Pig-Accumulator-in-Spark/m-p/130818#M31362</guid>
      <dc:creator>TimothySpann</dc:creator>
      <dc:date>2016-06-09T22:26:09Z</dc:date>
    </item>
    <item>
      <title>Re: Pig Accumulator in Spark</title>
      <link>https://community.cloudera.com/t5/Archives-of-Support-Questions/Pig-Accumulator-in-Spark/m-p/130819#M31363</link>
      <description>&lt;P&gt;I'm not aware of the concept of Spark's Accumulators exposed as "first-class" objects in Pig and have always advised that you would need to build a UDF for such activities if you couldn't simply get away with filtering the things to count (such as "good" records and "rejects") into separate aliases then count them up.  &lt;/P&gt;&lt;P&gt;Here is a blog post going down the UDF path; &lt;A href="https://dzone.com/articles/counters-apache-pig" target="_blank"&gt;https://dzone.com/articles/counters-apache-pig&lt;/A&gt;.  &lt;/P&gt;&lt;P&gt;Good luck &amp;amp; I'd love to hear if there was something I've been missing all along directly from Pig.&lt;/P&gt;</description>
      <pubDate>Fri, 10 Jun 2016 21:41:22 GMT</pubDate>
      <guid>https://community.cloudera.com/t5/Archives-of-Support-Questions/Pig-Accumulator-in-Spark/m-p/130819#M31363</guid>
      <dc:creator>LesterMartin</dc:creator>
      <dc:date>2016-06-10T21:41:22Z</dc:date>
    </item>
  </channel>
</rss>

