Package io.sbk.api.impl

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.

Field Summary

Fields inherited from class io.sbk.api.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 java.lang.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.

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.