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.

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. Accept the benchmarking data.
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.

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.

Description copied from interface: Callback

Accept the benchmarking data. if your storage driver is not interested in passing the data read; then below method can be overridden.

Specified by:

record in interface Callback<Object>

Parameters:

startTime - Start time

endTime - End Time.

dataSize - size of the data in bytes.

events - number of records/events/messages.

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.