Skip to content

make count(*) use a QuantifiedObjectValue.of(q) instead of an empty RCV#1

Open
normen662 wants to merge 1 commit intohatyo:refactor_aggregate_match_candidatefrom
normen662:refactor_aggregate_match_candidate
Open

make count(*) use a QuantifiedObjectValue.of(q) instead of an empty RCV#1
normen662 wants to merge 1 commit intohatyo:refactor_aggregate_match_candidatefrom
normen662:refactor_aggregate_match_candidate

Conversation

@normen662
Copy link

No description provided.

Comment on lines -246 to +260
final var aliasMap = AliasMap.identitiesFor(Sets.union(selectQunValue.getCorrelatedTo(), groupingValues.stream().flatMap(v -> v.getCorrelatedTo().stream()).collect(ImmutableSet.toImmutableSet())));
final var pulledUpGroupingValuesMap = selectQunValue.pullUp(groupingValues, aliasMap, ImmutableSet.of(), selectWhereQun.getAlias());
final var pulledUpGroupingValues = groupingValues.stream().map(groupingValue -> {
if (!pulledUpGroupingValuesMap.containsKey(groupingValue)) {
throw new RecordCoreException("could not pull grouping value " + groupingValue)
.addLogInfo(LogMessageKeys.VALUE, groupingValue);
}
return pulledUpGroupingValuesMap.get(groupingValue);
}).collect(ImmutableList.toImmutableList());
final var aliasMap = AliasMap.identitiesFor(
Sets.union(selectQunValue.getCorrelatedTo(),
groupingValues.stream().flatMap(v -> v.getCorrelatedTo().stream())
.collect(ImmutableSet.toImmutableSet())));
final var pulledUpGroupingValuesMap =
selectQunValue.pullUp(groupingValues, aliasMap, ImmutableSet.of(), selectWhereQun.getAlias());
final var pulledUpGroupingValues =
groupingValues.stream().map(groupingValue -> {
if (!pulledUpGroupingValuesMap.containsKey(groupingValue)) {
throw new RecordCoreException("could not pull grouping value " + groupingValue)
.addLogInfo(LogMessageKeys.VALUE, groupingValue);
}
return pulledUpGroupingValuesMap.get(groupingValue);
}).collect(ImmutableList.toImmutableList());

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

These are all white space/line break changes, right? Just making sure I'm not missing anything

hatyo pushed a commit that referenced this pull request Jan 10, 2025
Update build for relational subprojects
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants