Class SbkBenchmark

java.lang.Object

io.sbk.api.impl.SbkBenchmark

All Implemented Interfaces:

Benchmark

public final class SbkBenchmark
extends Object
implements Benchmark

Class for performing the benchmark.

This class orchestrates the full lifecycle of an SBK benchmark run: it opens the storage client, constructs writer and reader instances, wires PerL-based metric collectors, schedules timeouts and executes the writers/readers concurrently using an executor pool.

Responsibilities include:

• Opening and closing the storage device lifecycle via Storage.
• Creating and managing multiple DataWriter and DataReader instances.
• Coordinating PerL metric collectors for writers and readers when enabled.
• Providing a fault-tolerant shutdown path and reporting via the configured RWLogger.

Notes for maintainers:

• The class reserves executor threads based on configured writers/readers; adjust the thread accounting carefully.
• Perl-based metrics and timeouts are configured conditionally depending on writer/reader counts.

Constructor Summary

Constructors

Constructor	Description
SbkBenchmark(ParameterOptions params, Storage<Object> storage, DataType<Object> dType, @NotNull RWLogger rwLogger, io.time.Time time)	Create SBK Benchmark.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	start()	Start SBK Benchmark.
void	stop()	Stop/shutdown SBK Benchmark.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SbkBenchmark

public SbkBenchmark(ParameterOptions params,
 Storage<Object> storage,
 DataType<Object> dType,
 @NotNull
 @NotNull RWLogger rwLogger,
 io.time.Time time)
             throws IOException

Create SBK Benchmark.

Parameters:

params - Benchmarking input Parameters

storage - Storage device/client/driver for benchmarking

dType - Data Type.

rwLogger - output logger

time - time interface

Throws:

IOException - If Exception occurs.

Method Details

start

public CompletableFuture<Void> start()
                              throws IOException,
InterruptedException,
ExecutionException,
IllegalStateException

Start SBK Benchmark. opens the storage device/client , creates the writers/readers. conducts the performance benchmarking for given time in seconds or exits if the input the number of records are written/read. NOTE: This method does NOT invoke parsing of parameters, storage device/client.

Specified by:

start in interface Benchmark

Returns:

CompletableFuture that completes when the benchmark finishes

Throws:

IOException - If an exception occurred.

IllegalStateException - If an exception occurred.

InterruptedException - If an exception occurred

ExecutionException - If an exception occurred

stop

public void stop()

Stop/shutdown SBK Benchmark. closes all writers/readers. closes the storage device/client.

Specified by:

stop in interface Benchmark