I do not understand how the aggregate function works in Apache spark using python. I followed few websites for aggregate function, but could not able to understand how it function's.
Also I have few question. What is the need for identity value. How this aggregate function differ's from reduce function. How seq operation and combination operation output value changes when changing identity value?