-
Notifications
You must be signed in to change notification settings - Fork 3.7k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Correct aggregators violating names #16615
Conversation
I think that change is the finalization stuff in action; how the finalization happens after these changes? I'm not sure if forcing the column name would be the best - as for some reason the original aggfactory have decided to add a postagg - we can't really ignore that....if the base aggregate factory is not prepared to do the finalization implicitly then I guess that might go south...so I think we should probably look for some alternate path:
|
@kgyrtkirk can you please review the comments ? |
.queryContext(ImmutableMap.of( | ||
PlannerContext.CTX_ENABLE_WINDOW_FNS, true, | ||
QueryContexts.ENABLE_DEBUG, true, | ||
QueryContexts.WINDOWING_STRICT_VALIDATION, false |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this will break the other PR; so after one of these gets merged - to other needs updates
In case of few aggregators for example BloomSqlAggregator, BaseVarianceSqlAggregator etc, the aggName is being updated from a0 to a0:agg, breaching the contract as we would expect the aggName as the name which is passed. This is causing a mismatch while creating a column accessor. This commit aims to correct those violating sql aggregators.
Description
In case of few aggregators for example BloomSqlAggregator, BaseVarianceSqlAggregator etc, the aggName is being updated from
a0 to a0:agg
, breaching the contract as we would expect the aggName as the name which is passed. This is causing a mismatch while creating a column accessor.This commit aims to correct those violating sql aggregators.
Key changed/added classes in this PR
CompressedBigDecimalSqlAggregatorBase
TDigestGenerateSketchSqlAggregator
DoublesSketchObjectSqlAggregator
BloomFilterSqlAggregator
BaseVarianceSqlAggregator
This PR has: