Modified UDAGG example and added new sample file and image files

Examples/Extensibility-Simple-Examples/Extensibility-Simple-Examples/Script.usql

@@ -2,7 +2,7 @@
 This script uses user defined operators and aggregates 
 */
 
-DECLARE @INPUT_FILE string = @"/Samples/Data/AmbulanceData/Drivers_shorter.txt";
+DECLARE @INPUT_FILE string = @"/Samples/Data/AmbulanceData/Drivers.txt";
 
 //Extract first and last names as separate columns using a custom extractor
 @drivers =
@@ -45,13 +45,18 @@ OUTPUT @drivers_processed
 TO @"/Samples/Output/drivers_processed.txt"
 USING Outputters.Csv(quoting:false);
 
-//Use a user defined aggregator to count the drivers from countries that you want to specify
-@driver_count =
-    SELECT country,
-           AGG<Samples.SampleAggregate>(country) AS count
-    FROM @drivers
-    GROUP BY country;
+//Use a user defined aggregator to calculate balance
+//If the transaction type is "Debit", subtract from the balance, if the transaction type is "Credit", add to the balance
+@transactions =
+    EXTRACT transaction string,
+            amount int
+    FROM @"/Samples/Data/transactions.txt"
+    USING Extractors.Csv();
 
-OUTPUT @driver_count
-TO @"/Samples/Output/driver_count.txt"
+@balance =
+    SELECT AGG<Samples.SampleAggregate>(transaction, amount) AS balance
+    FROM @transactions;
+
+OUTPUT @balance
+TO @"/Samples/Output/balance.txt"
 USING Outputters.Csv();

Examples/Extensibility-Simple-Examples/Extensibility-Simple-Examples/Script.usql.cs

@@ -86,29 +86,31 @@ public override IRow Process(IRow input, IUpdatableRow output)
         }
     }
 
-    //User defined aggregate to calculate count of drivers from each region (North America, South America, Europe)
-    public class SampleAggregate : IAggregate<string, int>
+    //User defined aggregate to calculate the total balance by adding or subtracting based on whether its credit or debit
+    public class SampleAggregate : IAggregate<string, int, int>
     {
-        int count;
-        List<string> countries;
-
+        int balance;
+
         public override void Init()
         {
-            count = 0;
-            countries = new List<string>() { "Germany", "Mexico", "Argentina", "Spain", "UK" };
+            balance = 0;
         }
 
-        public override void Accumulate(string country)
+        public override void Accumulate(string transaction, int amount)
         {
-            if (countries.Contains(country))
+            if(transaction == "Credit")
+            {
+                balance += amount;
+            }
+            if(transaction == "Debit")
             {
-                count += 1;
+                balance -= amount;
             }
         }
 
         public override int Terminate()
         {
-            return count;
+            return balance;
         }
 
     }

Examples/Extensibility-Simple-Examples/readme.md

@@ -2,4 +2,4 @@
 
 This directory contains a sample project that shows how custom code can be used as inline C#, user defined functions (UDFs), user defined objects (UDOs) or user defined aggregates (UDAGGs) in U-SQL
 
-The project operates on Drivers.txt found in \Samples\Data\AmbulanceDemos folder.
+The project operates on Drivers.txt found in \Samples\Data\AmbulanceDemos folder and transactions.txt found in the \Samples\Data folder.

Examples/Samples/Data/transactions.txt

@@ -0,0 +1,10 @@
+Debit,100
+Credit,500
+Credit,200
+Credit,700
+Debit,50
+Debit,40
+Credit,670
+Debit,500
+Credit,1000
+Debit,100