Class SbkReader

java.lang.Object

io.sbk.api.Worker

io.sbk.api.impl.SbkReader

All Implemented Interfaces:

io.perl.api.RunBenchmark

public final class SbkReader
extends Worker
implements io.perl.api.RunBenchmark

Reader Benchmarking Implementation.

This class adapts a DataReader into the SBK harness by implementing the RunBenchmark contract. It wires the reader instance with per-worker context (id, params, perlChannel) and exposes a set of pre-built benchmark variants (time-based, count-based, with/without rate control and optional per-request logging).

Key behavior:

• The run(long,long) method executes asynchronously on the supplied executor and returns a CompletableFuture.
• Depending on ParameterOptions, the class selects specialized benchmark paths (e.g. RecordsReaderRateControl).
• It uses SbkRateController to pace reads when a records-per-second limit is provided.

Implementors and maintainers: keep this class focused on orchestration — the actual I/O semantics live in the driver-provided DataReader implementation, which may override default 'recordRead' helpers for batching or more efficient reads.

Field Summary

Fields inherited from class Worker

id, params, perlChannel

Constructor Summary

Constructors

Constructor	Description
SbkReader(int readerId, ParameterOptions params, io.perl.api.PerlChannel perlChannel, DataType<Object> dType, io.time.Time time, DataReader<Object> reader, CountReaders rCount, ReadRequestsLogger readRequestsLogger, ExecutorService executor)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	run(long secondsToRun, long recordsCount)

Methods inherited from class Object

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

Constructor Details

SbkReader

public SbkReader(int readerId,
 ParameterOptions params,
 io.perl.api.PerlChannel perlChannel,
 DataType<Object> dType,
 io.time.Time time,
 DataReader<Object> reader,
 CountReaders rCount,
 ReadRequestsLogger readRequestsLogger,
 ExecutorService executor)

Method Details

run

public CompletableFuture<Void> run(long secondsToRun,
 long recordsCount)
                            throws IOException,
EOFException,
IllegalStateException

Specified by:

run in interface io.perl.api.RunBenchmark

Throws:

IOException

EOFException

IllegalStateException