Package io.sbk.api.impl

Class SbkWriter

java.lang.Object

io.sbk.api.Worker

io.sbk.api.impl.SbkWriter

All Implemented Interfaces:

io.perl.api.RunBenchmark

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

Writer Benchmarking Implementation.

Field Summary

Fields inherited from class io.sbk.api.Worker

id, params, perlChannel

Constructor Summary

Constructors

Constructor	Description
SbkWriter(int writerID, ParameterOptions params, io.perl.api.PerlChannel perlChannel, @NotNull DataType<Object> dType, io.time.Time time, DataWriter<Object> writer, CountWriters wCount, WriteRequestsLogger requestsLogger, 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

SbkWriter

public SbkWriter(int writerID,
 ParameterOptions params,
 io.perl.api.PerlChannel perlChannel,
 @NotNull
 @NotNull DataType<Object> dType,
 io.time.Time time,
 DataWriter<Object> writer,
 CountWriters wCount,
 WriteRequestsLogger requestsLogger,
 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