Package io.sbk.api.impl

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.

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 java.lang.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.

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