forked from opensearch-project/OpenSearch
-
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.
[Tiered Caching] Adds stats implementation for TieredSpilloverCache (o…
…pensearch-project#13236) Stats rework part 4 of 4 --------- Signed-off-by: Peter Alfonsi <[email protected]> Co-authored-by: Peter Alfonsi <[email protected]>
- Loading branch information
1 parent
46944cb
commit a5c5675
Showing
12 changed files
with
754 additions
and
100 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
250 changes: 203 additions & 47 deletions
250
...les/cache-common/src/main/java/org/opensearch/cache/common/tier/TieredSpilloverCache.java
Large diffs are not rendered by default.
Oops, something went wrong.
161 changes: 161 additions & 0 deletions
161
...ommon/src/main/java/org/opensearch/cache/common/tier/TieredSpilloverCacheStatsHolder.java
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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,161 @@ | ||
| /* | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| * | ||
| * The OpenSearch Contributors require contributions made to | ||
| * this file be licensed under the Apache-2.0 license or a | ||
| * compatible open source license. | ||
| */ | ||
|
|
||
| package org.opensearch.cache.common.tier; | ||
|
|
||
| import org.opensearch.common.cache.stats.DefaultCacheStatsHolder; | ||
|
|
||
| import java.util.ArrayList; | ||
| import java.util.List; | ||
| import java.util.function.Consumer; | ||
|
|
||
| /** | ||
| * A tier-aware version of DefaultCacheStatsHolder. Overrides the incrementer functions, as we can't just add the on-heap | ||
| * and disk stats to get a total for the cache as a whole. If the disk tier is present, the total hits, size, and entries | ||
| * should be the sum of both tiers' values, but the total misses and evictions should be the disk tier's values. | ||
| * When the disk tier isn't present, on-heap misses and evictions should contribute to the total. | ||
| * | ||
| * For example, if the heap tier has 5 misses and the disk tier has 4, the total cache has had 4 misses, not 9. | ||
| * The same goes for evictions. Other stats values add normally. | ||
| * | ||
| * This means for misses and evictions, if we are incrementing for the on-heap tier and the disk tier is present, | ||
| * we have to increment only the leaf nodes corresponding to the on-heap tier itself, and not its ancestors, | ||
| * which correspond to totals including both tiers. If the disk tier is not present, we do increment the ancestor nodes. | ||
| */ | ||
| public class TieredSpilloverCacheStatsHolder extends DefaultCacheStatsHolder { | ||
|
|
||
| /** Whether the disk cache is currently enabled. */ | ||
| private boolean diskCacheEnabled; | ||
|
|
||
| // Common values used for tier dimension | ||
|
|
||
| /** The name for the tier dimension. */ | ||
| public static final String TIER_DIMENSION_NAME = "tier"; | ||
|
|
||
| /** Dimension value for on-heap cache, like OpenSearchOnHeapCache.*/ | ||
| public static final String TIER_DIMENSION_VALUE_ON_HEAP = "on_heap"; | ||
|
|
||
| /** Dimension value for on-disk cache, like EhcacheDiskCache. */ | ||
| public static final String TIER_DIMENSION_VALUE_DISK = "disk"; | ||
|
|
||
| /** | ||
| * Constructor for the stats holder. | ||
| * @param originalDimensionNames the original dimension names, not including TIER_DIMENSION_NAME | ||
| * @param diskCacheEnabled whether the disk tier starts out enabled | ||
| */ | ||
| public TieredSpilloverCacheStatsHolder(List<String> originalDimensionNames, boolean diskCacheEnabled) { | ||
| super( | ||
| getDimensionNamesWithTier(originalDimensionNames), | ||
| TieredSpilloverCache.TieredSpilloverCacheFactory.TIERED_SPILLOVER_CACHE_NAME | ||
| ); | ||
| this.diskCacheEnabled = diskCacheEnabled; | ||
| } | ||
|
|
||
| private static List<String> getDimensionNamesWithTier(List<String> dimensionNames) { | ||
| List<String> dimensionNamesWithTier = new ArrayList<>(dimensionNames); | ||
| dimensionNamesWithTier.add(TIER_DIMENSION_NAME); | ||
| return dimensionNamesWithTier; | ||
| } | ||
|
|
||
| /** | ||
| * Add tierValue to the end of a copy of the initial dimension values, so they can appropriately be used in this stats holder. | ||
| */ | ||
| List<String> getDimensionsWithTierValue(List<String> initialDimensions, String tierValue) { | ||
| List<String> result = new ArrayList<>(initialDimensions); | ||
| result.add(tierValue); | ||
| return result; | ||
| } | ||
|
|
||
| private String validateTierDimensionValue(List<String> dimensionValues) { | ||
| String tierDimensionValue = dimensionValues.get(dimensionValues.size() - 1); | ||
| assert tierDimensionValue.equals(TIER_DIMENSION_VALUE_ON_HEAP) || tierDimensionValue.equals(TIER_DIMENSION_VALUE_DISK) | ||
| : "Invalid tier dimension value"; | ||
| return tierDimensionValue; | ||
| } | ||
|
|
||
| @Override | ||
| public void incrementHits(List<String> dimensionValues) { | ||
| validateTierDimensionValue(dimensionValues); | ||
| // Hits from either tier should be included in the total values. | ||
| super.incrementHits(dimensionValues); | ||
| } | ||
|
|
||
| @Override | ||
| public void incrementMisses(List<String> dimensionValues) { | ||
| final String tierValue = validateTierDimensionValue(dimensionValues); | ||
|
|
||
| // If the disk tier is present, only misses from the disk tier should be included in total values. | ||
| Consumer<Node> missIncrementer = (node) -> { | ||
| if (tierValue.equals(TIER_DIMENSION_VALUE_ON_HEAP) && diskCacheEnabled) { | ||
| // If on-heap tier, increment only the leaf node corresponding to the on heap values; not the total values in its parent | ||
| // nodes | ||
| if (node.isAtLowestLevel()) { | ||
| node.incrementMisses(); | ||
| } | ||
| } else { | ||
| // If disk tier, or on-heap tier with a disabled disk tier, increment the leaf node and its parents | ||
| node.incrementMisses(); | ||
| } | ||
| }; | ||
| internalIncrement(dimensionValues, missIncrementer, true); | ||
| } | ||
|
|
||
| @Override | ||
| public void incrementEvictions(List<String> dimensionValues) { | ||
| final String tierValue = validateTierDimensionValue(dimensionValues); | ||
|
|
||
| // If the disk tier is present, only evictions from the disk tier should be included in total values. | ||
| Consumer<DefaultCacheStatsHolder.Node> evictionsIncrementer = (node) -> { | ||
| if (tierValue.equals(TIER_DIMENSION_VALUE_ON_HEAP) && diskCacheEnabled) { | ||
| // If on-heap tier, increment only the leaf node corresponding to the on heap values; not the total values in its parent | ||
| // nodes | ||
| if (node.isAtLowestLevel()) { | ||
| node.incrementEvictions(); | ||
| } | ||
| } else { | ||
| // If disk tier, or on-heap tier with a disabled disk tier, increment the leaf node and its parents | ||
| node.incrementEvictions(); | ||
| } | ||
| }; | ||
| internalIncrement(dimensionValues, evictionsIncrementer, true); | ||
| } | ||
|
|
||
| @Override | ||
| public void incrementSizeInBytes(List<String> dimensionValues, long amountBytes) { | ||
| validateTierDimensionValue(dimensionValues); | ||
| // Size from either tier should be included in the total values. | ||
| super.incrementSizeInBytes(dimensionValues, amountBytes); | ||
| } | ||
|
|
||
| // For decrements, we should not create nodes if they are absent. This protects us from erroneously decrementing values for keys | ||
| // which have been entirely deleted, for example in an async removal listener. | ||
| @Override | ||
| public void decrementSizeInBytes(List<String> dimensionValues, long amountBytes) { | ||
| validateTierDimensionValue(dimensionValues); | ||
| // Size from either tier should be included in the total values. | ||
| super.decrementSizeInBytes(dimensionValues, amountBytes); | ||
| } | ||
|
|
||
| @Override | ||
| public void incrementItems(List<String> dimensionValues) { | ||
| validateTierDimensionValue(dimensionValues); | ||
| // Entries from either tier should be included in the total values. | ||
| super.incrementItems(dimensionValues); | ||
| } | ||
|
|
||
| @Override | ||
| public void decrementItems(List<String> dimensionValues) { | ||
| validateTierDimensionValue(dimensionValues); | ||
| // Entries from either tier should be included in the total values. | ||
| super.decrementItems(dimensionValues); | ||
| } | ||
|
|
||
| void setDiskCacheEnabled(boolean diskCacheEnabled) { | ||
| this.diskCacheEnabled = diskCacheEnabled; | ||
| } | ||
| } |
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.