Re: [E] Re: parallel aggregation

2023-04-13 Thread Alexander Saydakov
Still not quite clear: 1. I wonder if there is a clean separation between the phases: once partial aggregation is done only combining is done after that (state transition function never receives results of combining). 2. Can a combiner output also go through serial-deserial before hitting another c

Re: [E] Re: parallel aggregation

2023-04-12 Thread David Rowley
On Thu, 13 Apr 2023 at 14:31, Alexander Saydakov wrote: > 1. I wonder if there is a clean separation between the phases: once partial > aggregation is done only combining is done after that (state transition > function never receives results of combining). Currently the transfn won't be called

Re: [E] Re: parallel aggregation

2023-04-12 Thread David Rowley
(Let's keep this on this list) On Thu, 13 Apr 2023 at 12:08, Alexander Saydakov wrote: > > Yes, I am talking about a custom aggregate in C++ with internal state type. > You did not really answer my first question. Does the state always go through > serialfinc-deserialfunc before reaching a combi

Re: parallel aggregation

2023-04-12 Thread David Rowley
On Wed, 12 Apr 2023 at 22:14, Alexander Saydakov wrote: > > I have a few questions regarding aggregate functions that would be parallel > safe. > 1. do the inputs of combinefunc always go through serialfunc-deserialfunc or > they can come directly from sfunc (worker on the same machine, perhaps)