You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by ru...@apache.org on 2025/05/22 23:50:13 UTC
(cassandra-easy-stress) branch main updated: Fixed several formatting errors
This is an automated email from the ASF dual-hosted git repository.
rustyrazorblade pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/cassandra-easy-stress.git
The following commit(s) were added to refs/heads/main by this push:
new b38dca7 Fixed several formatting errors
b38dca7 is described below
commit b38dca77954e1a2eac638b54ff9fc9162cb8de14
Author: Jon Haddad <jo...@jonhaddad.com>
AuthorDate: Thu May 22 16:50:08 2025 -0700
Fixed several formatting errors
---
src/main/kotlin/com/rustyrazorblade/easycassstress/Metrics.kt | 3 +++
.../kotlin/com/rustyrazorblade/easycassstress/OperationCallback.kt | 2 +-
src/main/kotlin/com/rustyrazorblade/easycassstress/ProfileRunner.kt | 4 +---
.../kotlin/com/rustyrazorblade/easycassstress/RateLimiterOptimizer.kt | 4 +---
4 files changed, 6 insertions(+), 7 deletions(-)
diff --git a/src/main/kotlin/com/rustyrazorblade/easycassstress/Metrics.kt b/src/main/kotlin/com/rustyrazorblade/easycassstress/Metrics.kt
index 40203d2..722868c 100644
--- a/src/main/kotlin/com/rustyrazorblade/easycassstress/Metrics.kt
+++ b/src/main/kotlin/com/rustyrazorblade/easycassstress/Metrics.kt
@@ -94,7 +94,10 @@ class Metrics(val metricRegistry: MetricRegistry, val reporters: List<ScheduledR
}
fun getSelectThroughput() = selectThroughputTracker.getCurrentThroughput()
+
fun getMutationThroughput() = mutationThroughputTracker.getCurrentThroughput()
+
fun getDeletionThroughput() = deletionThroughputTracker.getCurrentThroughput()
+
fun getPopulateThroughput() = populateThroughputTracker.getCurrentThroughput()
}
diff --git a/src/main/kotlin/com/rustyrazorblade/easycassstress/OperationCallback.kt b/src/main/kotlin/com/rustyrazorblade/easycassstress/OperationCallback.kt
index bd87176..3dd8ad9 100644
--- a/src/main/kotlin/com/rustyrazorblade/easycassstress/OperationCallback.kt
+++ b/src/main/kotlin/com/rustyrazorblade/easycassstress/OperationCallback.kt
@@ -52,7 +52,7 @@ class OperationCallback(
// Handle pagination in driver v4
if (paginate && result != null) {
// Fetch next page - this could be made async but we'll keep it simple for now
- while(result.hasMorePages()) {
+ while (result.hasMorePages()) {
result.fetchNextPage()
}
}
diff --git a/src/main/kotlin/com/rustyrazorblade/easycassstress/ProfileRunner.kt b/src/main/kotlin/com/rustyrazorblade/easycassstress/ProfileRunner.kt
index a23a059..c94d6e6 100644
--- a/src/main/kotlin/com/rustyrazorblade/easycassstress/ProfileRunner.kt
+++ b/src/main/kotlin/com/rustyrazorblade/easycassstress/ProfileRunner.kt
@@ -17,7 +17,6 @@
*/
package com.rustyrazorblade.easycassstress
-import com.datastax.oss.driver.api.core.cql.AsyncResultSet
import com.datastax.oss.driver.api.core.cql.SimpleStatement
import com.rustyrazorblade.easycassstress.workloads.IStressProfile
import com.rustyrazorblade.easycassstress.workloads.Operation
@@ -26,7 +25,6 @@ import java.time.Duration
import java.time.LocalTime
import java.time.format.DateTimeFormatter
import java.time.format.FormatStyle
-import java.util.function.BiConsumer
class PartitionKeyGeneratorException : Exception()
@@ -215,7 +213,7 @@ class ProfileRunner(
)
future.whenComplete { result, error ->
- callback.accept(result, error)
+ callback.accept(result, error)
}
}
} catch (_: OperationStopException) {
diff --git a/src/main/kotlin/com/rustyrazorblade/easycassstress/RateLimiterOptimizer.kt b/src/main/kotlin/com/rustyrazorblade/easycassstress/RateLimiterOptimizer.kt
index bbe7d96..c7aa434 100644
--- a/src/main/kotlin/com/rustyrazorblade/easycassstress/RateLimiterOptimizer.kt
+++ b/src/main/kotlin/com/rustyrazorblade/easycassstress/RateLimiterOptimizer.kt
@@ -157,7 +157,7 @@ class RateLimiterOptimizer(
fun getCurrentTotalThroughput(): Double {
return metrics.getSelectThroughput() +
- metrics.getMutationThroughput() +
+ metrics.getMutationThroughput() +
metrics.getDeletionThroughput() +
metrics.getPopulateThroughput()
}
@@ -320,6 +320,4 @@ class RateLimiterOptimizer(
isStepPhase = true
rateLimiter.rate = stepValue
}
-
-
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org