This is an automated email from the ASF dual-hosted git repository.
pingtimeout pushed a commit to branch benchmarks-ppc
in repository https://gitbox.apache.org/repos/asf/polaris-tools.git
commit f74718e3a316bf3bcf62871db189e86f28b8dd9d
Author: Pierre Laporte <pie...@pingtimeout.fr>
AuthorDate: Mon Jun 2 18:27:43 2025 +0200
Minor code refactor
---
.../simulations/ReadUpdateTreeDataset.scala | 31 +++++++++++-----------
1 file changed, 15 insertions(+), 16 deletions(-)
diff --git
a/benchmarks/src/gatling/scala/org/apache/polaris/benchmarks/simulations/ReadUpdateTreeDataset.scala
b/benchmarks/src/gatling/scala/org/apache/polaris/benchmarks/simulations/ReadUpdateTreeDataset.scala
index 4d5ebb9..2304920 100644
---
a/benchmarks/src/gatling/scala/org/apache/polaris/benchmarks/simulations/ReadUpdateTreeDataset.scala
+++
b/benchmarks/src/gatling/scala/org/apache/polaris/benchmarks/simulations/ReadUpdateTreeDataset.scala
@@ -54,7 +54,6 @@ class ReadUpdateTreeDataset extends Simulation {
//
--------------------------------------------------------------------------------
// Helper values
//
--------------------------------------------------------------------------------
- private val numNamespaces: Int = dp.nAryTree.numberOfNodes
private val accessToken: AtomicReference[String] = new AtomicReference()
private val shouldRefreshToken: AtomicBoolean = new AtomicBoolean(true)
@@ -64,6 +63,21 @@ class ReadUpdateTreeDataset extends Simulation {
private val tblActions = TableActions(dp, wp, accessToken)
private val viewActions = ViewActions(dp, wp, accessToken)
+ private val nsListFeeder = new
CircularIterator(nsActions.namespaceIdentityFeeder)
+ private val nsExistsFeeder = new
CircularIterator(nsActions.namespaceIdentityFeeder)
+ private val nsFetchFeeder = new
CircularIterator(nsActions.namespaceFetchFeeder)
+ private val nsUpdateFeeder = nsActions.namespacePropertiesUpdateFeeder()
+
+ private val tblListFeeder = new
CircularIterator(tblActions.tableIdentityFeeder)
+ private val tblExistsFeeder = new
CircularIterator(tblActions.tableIdentityFeeder)
+ private val tblFetchFeeder = new
CircularIterator(tblActions.tableFetchFeeder)
+ private val tblUpdateFeeder = tblActions.propertyUpdateFeeder()
+
+ private val viewListFeeder = new
CircularIterator(viewActions.viewIdentityFeeder)
+ private val viewExistsFeeder = new
CircularIterator(viewActions.viewIdentityFeeder)
+ private val viewFetchFeeder = new
CircularIterator(viewActions.viewFetchFeeder)
+ private val viewUpdateFeeder = viewActions.propertyUpdateFeeder()
+
//
--------------------------------------------------------------------------------
// Authentication related workloads:
// * Authenticate and store the access token for later use every minute
@@ -91,21 +105,6 @@ class ReadUpdateTreeDataset extends Simulation {
session
}
- private val nsListFeeder = new
CircularIterator(nsActions.namespaceIdentityFeeder)
- private val nsExistsFeeder = new
CircularIterator(nsActions.namespaceIdentityFeeder)
- private val nsFetchFeeder = new
CircularIterator(nsActions.namespaceFetchFeeder)
- private val nsUpdateFeeder = nsActions.namespacePropertiesUpdateFeeder()
-
- private val tblListFeeder = new
CircularIterator(tblActions.tableIdentityFeeder)
- private val tblExistsFeeder = new
CircularIterator(tblActions.tableIdentityFeeder)
- private val tblFetchFeeder = new
CircularIterator(tblActions.tableFetchFeeder)
- private val tblUpdateFeeder = tblActions.propertyUpdateFeeder()
-
- private val viewListFeeder = new
CircularIterator(viewActions.viewIdentityFeeder)
- private val viewExistsFeeder = new
CircularIterator(viewActions.viewIdentityFeeder)
- private val viewFetchFeeder = new
CircularIterator(viewActions.viewFetchFeeder)
- private val viewUpdateFeeder = viewActions.propertyUpdateFeeder()
-
//
--------------------------------------------------------------------------------
// Workload: Randomly read and write entities
//
--------------------------------------------------------------------------------
