Skip to content

Commit 58ea23d

Browse files
committed
Update DualKeyCacheImpl.java
1 parent 646418c commit 58ea23d

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

  • iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/dualkeycache/impl

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/dualkeycache/impl/DualKeyCacheImpl.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,6 @@ public <R> boolean batchApply(
8484
if (cacheEntryGroup == null) {
8585
return false;
8686
}
87-
8887
for (final Map.Entry<SK, R> skrEntry : fkMapEntry.getValue().entrySet()) {
8988
final T cacheEntry = cacheEntryGroup.getCacheEntry(skrEntry.getKey());
9089
if (cacheEntry == null) {
@@ -105,6 +104,7 @@ public void update(
105104
final V value,
106105
final ToIntFunction<V> updater,
107106
final boolean createIfNotExists) {
107+
108108
ICacheEntryGroup<FK, SK, V, T> cacheEntryGroup = firstKeyMap.get(firstKey);
109109
if (Objects.isNull(cacheEntryGroup)) {
110110
if (createIfNotExists) {
@@ -350,6 +350,7 @@ private long getEntriesCount() {
350350
private static class SegmentedConcurrentHashMap<K, V> {
351351

352352
private static final int SLOT_NUM = 31;
353+
353354
private final Map<K, V>[] maps = new ConcurrentHashMap[SLOT_NUM];
354355

355356
V get(final K key) {

0 commit comments

Comments
 (0)