Skip to content

Commit

Permalink
Merge conflict resolution for Java11
Browse files Browse the repository at this point in the history
Signed-off-by: expani <anijainc@amazon.com>
  • Loading branch information
expani committed Jan 29, 2025
1 parent 8caaa49 commit 2dd1ce1
Show file tree
Hide file tree
Showing 3 changed files with 19 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -172,11 +172,13 @@ private static boolean validateDateHistogramSupport(
CompositeDataCubeFieldType compositeIndexFieldInfo,
AggregatorFactory aggregatorFactory
) {
if (!(aggregatorFactory instanceof DateHistogramAggregatorFactory dateHistogramAggregatorFactory)
if (!(aggregatorFactory instanceof DateHistogramAggregatorFactory)
|| aggregatorFactory.getSubFactories().getFactories().length < 1) {
return false;
}

DateHistogramAggregatorFactory dateHistogramAggregatorFactory = (DateHistogramAggregatorFactory) aggregatorFactory;

// Find the DateDimension in the dimensions list
DateDimension starTreeDateDimension = null;
for (Dimension dimension : compositeIndexFieldInfo.getDimensions()) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,6 +34,7 @@
import java.util.Map;
import java.util.function.BiConsumer;
import java.util.function.Consumer;
import java.util.stream.Collectors;

/**
* Helper class for building star-tree query
Expand Down Expand Up @@ -146,7 +147,7 @@ public static Dimension getMatchingDimensionOrThrow(String dimensionName, List<D
}

public static Dimension getMatchingDimensionOrNull(String dimensionName, List<Dimension> orderedDimensions) {
List<Dimension> matchingDimensions = orderedDimensions.stream().filter(x -> x.getField().equals(dimensionName)).toList();
List<Dimension> matchingDimensions = orderedDimensions.stream().filter(x -> x.getField().equals(dimensionName)).collect(Collectors.toList());
if (matchingDimensions.size() != 1) {
return null;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -363,13 +363,20 @@ public Optional<Long> getMatchingOrdinal(
case GTE:
return seekStatus == TermsEnum.SeekStatus.END ? Optional.empty() : Optional.of(termsEnum.ord());
case GT:
return switch (seekStatus) {
case END -> Optional.empty();
case FOUND -> ((termsEnum.ord() + 1) < sortedSetIterator.getValueCount())
? Optional.of(termsEnum.ord() + 1)
: Optional.empty();
case NOT_FOUND -> Optional.of(termsEnum.ord());
};
switch (seekStatus) {
case END:
return Optional.empty();
case FOUND:
if ((termsEnum.ord() + 1) < sortedSetIterator.getValueCount()) {
return Optional.of(termsEnum.ord() + 1);
} else {
return Optional.empty();
}
case NOT_FOUND:
return Optional.of(termsEnum.ord());
default:
throw new IllegalStateException("Unexpected value: " + seekStatus);
}
case LTE:
if (seekStatus == TermsEnum.SeekStatus.NOT_FOUND) {
return ((termsEnum.ord() - 1) >= 0) ? Optional.of(termsEnum.ord() - 1) : Optional.empty();
Expand Down

0 comments on commit 2dd1ce1

Please sign in to comment.