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

more renames

This commit is contained in:
Marcus Eriksson 2024-04-22 11:10:12 +02:00
parent 9297418a14
commit 3b4bdb6590
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/java/org/apache/cassandra/tcm/ownership/ReplicaGroups.java
View File

@ -138,7 +138,7 @@ public class ReplicaGroups
int pos = ordering.binarySearchAsymmetric(ranges, token, AsymmetricOrdering.Op.CEIL);
if (pos >= 0 && pos < endpoints.size())
return endpoints.get(pos);
throw new IllegalStateException("Could not find range for token " + token + " in PlacementForRange: " + this);
throw new IllegalStateException("Could not find range for token " + token + " in ReplicaGroups: " + this);
}
public VersionedEndpoints.ForToken forToken(Token token)

14
test/microbench/org/apache/cassandra/test/microbench/PlacementForRangeBench.java → test/microbench/org/apache/cassandra/test/microbench/ReplicaGroupsBench.java
View File

@ -65,15 +65,15 @@ import org.openjdk.jmh.runner.options.OptionsBuilder;
@Fork(value = 1)
@Warmup(iterations = 5, timeUnit = TimeUnit.MILLISECONDS, time = 5000)
@Measurement(iterations = 5, timeUnit = TimeUnit.MILLISECONDS, time = 5000)
public class PlacementForRangeBench
public class ReplicaGroupsBench
{
static Token [] queryTokens = new Token[5000];
static Random random = new Random(1);
static ReplicaGroups pfr;
static ReplicaGroups replicaGroups;
/*
new: PlacementForRangeBench.bench avgt 5 0,317 ± 0,037 ms/op
new: ReplicaGroupBench.bench avgt 5 0,317 ± 0,037 ms/op
old: PlacementForRangeBench.bench avgt 5 10,187 ± 0,040 ms/op
old: ReplicaGroupBench.bench avgt 5 10,187 ± 0,040 ms/op
*/
@Setup(Level.Trial)
@ -85,14 +85,14 @@ old: PlacementForRangeBench.bench avgt 5 10,187 ± 0,040 ms/op
queryTokens[i] = Murmur3Partitioner.instance.getRandomToken(random);
Keyspaces keyspaces = fakeKeyspaces(6);
ReplicationParams params = keyspaces.get("pfrbench").get().params.replication;
pfr = new UniformRangePlacement().calculatePlacements(Epoch.FIRST, fakeMetadata(nodecount), keyspaces).get(params).reads;
replicaGroups = new UniformRangePlacement().calculatePlacements(Epoch.FIRST, fakeMetadata(nodecount), keyspaces).get(params).reads;
}
@Benchmark
public void bench()
{
for (Token t : queryTokens)
pfr.forRange(t);
replicaGroups.forRange(t);
}
public ClusterMetadata fakeMetadata(int nodeCount) throws UnknownHostException
@ -131,7 +131,7 @@ old: PlacementForRangeBench.bench avgt 5 10,187 ± 0,040 ms/op
public static void main(String[] args) throws RunnerException
{
Options options = new OptionsBuilder()
.include(PlacementForRangeBench.class.getSimpleName())
.include(ReplicaGroupsBench.class.getSimpleName())
.build();
new Runner(options).run();
}