Misinformed DNA on Wed, 03 Aug 2016 16:53:54
For a given grouping, I want to sum values in a column from previous rows and subtract the value in the same column for the current row. This was initially coded as a custom Processor, but I can't find a way to sort and group the values. I see PRESORT exists for Reducer, but I haven't found a way to use it in a Processor as I keep getting compile-time errors.
Another option is to use OVER() with a custom Aggregator, but I haven't found any documentation on how to do that.
Thoughts on how best to do this or further documentation?
MRys on Mon, 08 Aug 2016 19:40:55
PRESORT only exists for reducers. Why can't you try using a reducer (that aggregates the values but does produce one output row per input)?
Custom aggregators are currently not supported with the OVER expression. Please file a request at http://aka.ms/adlfeedback.
Misinformed DNA on Tue, 09 Aug 2016 15:02:46
Reducer worked great!