natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge 37c6f3766c into 10557d7ffe

This commit is contained in:
Dmitry Kryukov 2026-08-01 14:11:46 +03:00 committed by GitHub
parent 10557d7ffe 37c6f3766c
commit 0a76abddc7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/java/org/apache/cassandra/db/compaction/ShardManagerDiskAware.java
View File

@ -36,7 +36,6 @@ public class ShardManagerDiskAware extends ShardManagerNoDisks
* share owned by the node.
*/
private final double[] diskBoundaryPositions;
private final int[] diskStartRangeIndex;
private final List<Token> diskBoundaries;
public ShardManagerDiskAware(ColumnFamilyStore.VersionedLocalRanges localRanges, List<Token> diskBoundaries)
@ -49,8 +48,6 @@ public class ShardManagerDiskAware extends ShardManagerNoDisks
final List<Splitter.WeightedRange> ranges = localRanges;
int diskIndex = 0;
diskBoundaryPositions = new double[diskBoundaries.size()];
diskStartRangeIndex = new int[diskBoundaryPositions.length];
diskStartRangeIndex[0] = 0;
for (int i = 0; i < localRangePositions.length; ++i)
{
@ -65,7 +62,6 @@ public class ShardManagerDiskAware extends ShardManagerNoDisks
if (leftPart > span) // if the boundary falls on left or before it
leftPart = 0;
diskBoundaryPositions[diskIndex] = position + leftPart;
diskStartRangeIndex[diskIndex + 1] = i;
++diskIndex;
diskBoundary = diskBoundaries.get(diskIndex);
}