Package io.sbk.api.impl

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.

Field Summary

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