Class SbkCallbackReader

java.lang.Object

io.sbk.api.Worker

io.sbk.api.impl.SbkCallbackReader

All Implemented Interfaces:

Benchmark, Callback<Object>

@Deprecated
public final class SbkCallbackReader
extends Worker
implements Callback<Object>, Benchmark

Deprecated.

This interface is replaced by Abstract class AbstractCallbackReader and SbkReader.

SBK Callback reader implementation.

This deprecated helper adapts callback-style drivers into the older SBK Benchmark interface. It is retained for backwards compatibility but has been superseded by the SbkReader / AbstractCallbackReader classes which provide richer orchestration and explicit lifecycle management.

If you are maintaining drivers, prefer implementing a DataReader (synchronous or asynchronous) and integrate with SbkReader instead of using this deprecated callback path.

Field Summary

Fields inherited from class Worker

id, params, perlChannel

Constructor Summary

Constructors

Constructor	Description
SbkCallbackReader(int readerId, ParameterOptions params, io.perl.api.PerlChannel perlChannel, int idMax, DataType<Object> dataType, io.time.Time time)	Deprecated. Creates the deprecated callback-based benchmark reader.

Method Summary

Modifier and Type	Method	Description
void	consume(Object data)	Deprecated. Consume the data.
void	record(long startTime, long endTime, int dataSize, int events)	Deprecated. Records a completed callback batch and completes the benchmark when its configured duration or record target is reached.
CompletableFuture<Void>	start()	Deprecated. Start the Benchmark.
void	stop()	Deprecated. stop/shutdown the Benchmark.

Methods inherited from class Object

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

Constructor Details

SbkCallbackReader

public SbkCallbackReader(int readerId,
 ParameterOptions params,
 io.perl.api.PerlChannel perlChannel,
 int idMax,
 DataType<Object> dataType,
 io.time.Time time)

Deprecated.

Creates the deprecated callback-based benchmark reader.

Parameters:

readerId - reader identifier

params - benchmark parameters

perlChannel - performance channel

idMax - maximum reader identifier

dataType - storage data type

time - benchmark time source

Method Details

start

public CompletableFuture<Void> start()

Deprecated.

Description copied from interface: Benchmark

Start the Benchmark.

Specified by:

start in interface Benchmark

Returns:

CompletableFuture that completes when the benchmark finishes

stop

public void stop()

Deprecated.

Description copied from interface: Benchmark

stop/shutdown the Benchmark.

Specified by:

stop in interface Benchmark

record

public void record(long startTime,
 long endTime,
 int dataSize,
 int events)

Deprecated.

Records a completed callback batch and completes the benchmark when its configured duration or record target is reached.

Specified by:

record in interface Callback<Object>

Parameters:

startTime - operation start time in the configured time unit

endTime - operation completion time in the configured time unit

dataSize - total bytes represented by the callback batch

events - number of records represented by the callback batch

consume

public void consume(Object data)

Deprecated.

Description copied from interface: Callback

Consume the data.

Specified by:

consume in interface Callback<Object>

Parameters:

data - data read from storage client/device.