forked from apache/datafusion
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Make FirstValue an UDAF, Change
AggregateUDFImpl::accumulator
signa…
…ture, support ORDER BY for UDAFs (apache#9874) * first draft Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * clippy fix Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * cleanup Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * use one vector for ordering req Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * add sort exprs to accumulator Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * clippy Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * cleanup Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * fix doc test Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * change to ref Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * fix typo Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * fix doc Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * fmt Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * move schema and logical ordering exprs Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * remove redudant info Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * rename Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * cleanup Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * add ignore nulls Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * fix conflict Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * backup Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * complete return_type Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * complete replace Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * split to first value udf Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * replace accumulator Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * fmt Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * cleanup Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * small fix Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * remove ordering types Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * make state fields more flexible Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * cleanup Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * replace done Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * cleanup Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * cleanup Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * rm comments Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * cleanup Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * rm test1 Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * fix state fields Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * fmt Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * args struct for accumulator Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * simplify Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * add sig Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * add comments Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * fmt Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * fix docs Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * use exprs utils Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * rm state type Signed-off-by: jayzhan211 <jayzhan211@gmail.com> * add comment Signed-off-by: jayzhan211 <jayzhan211@gmail.com> --------- Signed-off-by: jayzhan211 <jayzhan211@gmail.com>
- Loading branch information
1 parent
d2ba901
commit dfd4442
Showing
24 changed files
with
450 additions
and
134 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.