Package io.sbk.api

Interface DataWriter<T>

All Known Subinterfaces:

DataRecordsWriter<T>, Writer<T>

public sealed interface DataWriter<T>
permits DataRecordsWriter<T>

Interface for Basic Data Writers.

Method Summary

Modifier and Type	Method	Description
void	close()	Close the Writer.
void	RecordsWriter(Worker writer, long recordsCount, DataType<T> dType, T data, int size, io.time.Time time)	writer benchmarking by writing given number of records.
void	RecordsWriter(Worker writer, long recordsCount, DataType<T> dType, T data, int size, io.time.Time time, WriteRequestsLogger logger)	writer benchmarking by writing given number of records.
void	RecordsWriterRO(Worker writer, long recordsCount, DataType<T> dType, T data, int size, io.time.Time time, RateController rController)	Write given number of records.
void	RecordsWriterRO(Worker writer, long recordsCount, DataType<T> dType, T data, int size, io.time.Time time, RateController rController, WriteRequestsLogger logger)	Write given number of records.
void	RecordsWriterRW(Worker writer, long recordsCount, DataType<T> dType, T data, int size, io.time.Time time, RateController rController)	Write given number of records.
void	RecordsWriterRW(Worker writer, long recordsCount, DataType<T> dType, T data, int size, io.time.Time time, RateController rController, WriteRequestsLogger logger)	Write given number of records.
void	RecordsWriterSync(Worker writer, long recordsCount, DataType<T> dType, T data, int size, io.time.Time time, RateController rController)	Writer benchmarking by writing given number of records and data should synced is invoked after writing given set of records.
void	RecordsWriterSync(Worker writer, long recordsCount, DataType<T> dType, T data, int size, io.time.Time time, RateController rController, WriteRequestsLogger logger)	Writer benchmarking by writing given number of records and data should synced is invoked after writing given set of records.
void	RecordsWriterTime(Worker writer, long secondsToRun, DataType<T> dType, T data, int size, io.time.Time time)	Writer benchmarking by continuously writing data records for specific time duration.
void	RecordsWriterTime(Worker writer, long secondsToRun, DataType<T> dType, T data, int size, io.time.Time time, WriteRequestsLogger logger)	Writer benchmarking by continuously writing data records for specific time duration.
void	RecordsWriterTimeRO(Worker writer, long secondsToRun, DataType<T> dType, T data, int size, io.time.Time time, RateController rController)	Writing data records for specific time duration.
void	RecordsWriterTimeRO(Worker writer, long secondsToRun, DataType<T> dType, T data, int size, io.time.Time time, RateController rController, WriteRequestsLogger logger)	Writing data records for specific time duration.
void	RecordsWriterTimeRW(Worker writer, long secondsToRun, DataType<T> dType, T data, int size, io.time.Time time, RateController rController)	Writing data records for specific time duration.
void	RecordsWriterTimeRW(Worker writer, long secondsToRun, DataType<T> dType, T data, int size, io.time.Time time, RateController rController, WriteRequestsLogger logger)	Writing data records for specific time duration.
void	RecordsWriterTimeSync(Worker writer, long secondsToRun, DataType<T> dType, T data, int size, io.time.Time time, RateController rController)	writer benchmarking by continuously writing data records for specific time duration.
void	RecordsWriterTimeSync(Worker writer, long secondsToRun, DataType<T> dType, T data, int size, io.time.Time time, RateController rController, WriteRequestsLogger logger)	writer benchmarking by continuously writing data records for specific time duration.

Method Details

close

void close()
    throws IOException

Close the Writer.

Throws:

IOException - If an exception occurred.

RecordsWriter

void RecordsWriter(Worker writer,
 long recordsCount,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time)
            throws IOException

writer benchmarking by writing given number of records.

Parameters:

writer - Writer Descriptor

recordsCount - Records count

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

Throws:

IOException - If an exception occurred.

RecordsWriter

void RecordsWriter(Worker writer,
 long recordsCount,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time,
 WriteRequestsLogger logger)
            throws IOException

writer benchmarking by writing given number of records.

Parameters:

writer - Writer Descriptor

recordsCount - Records count

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

logger - log write requests

Throws:

IOException - If an exception occurred.

RecordsWriterSync

void RecordsWriterSync(Worker writer,
 long recordsCount,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time,
 RateController rController)
                throws IOException

Writer benchmarking by writing given number of records and data should synced is invoked after writing given set of records.

Parameters:

writer - Writer Descriptor

recordsCount - Records count

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

rController - Rate Controller

Throws:

IOException - If an exception occurred.

RecordsWriterSync

void RecordsWriterSync(Worker writer,
 long recordsCount,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time,
 RateController rController,
 WriteRequestsLogger logger)
                throws IOException

Writer benchmarking by writing given number of records and data should synced is invoked after writing given set of records.

Parameters:

writer - Writer Descriptor

recordsCount - Records count

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

rController - Rate Controller

logger - log write requests

Throws:

IOException - If an exception occurred.

RecordsWriterTime

void RecordsWriterTime(Worker writer,
 long secondsToRun,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time)
                throws IOException

Writer benchmarking by continuously writing data records for specific time duration. sync is invoked after writing records for given time.

Parameters:

writer - Writer Descriptor

secondsToRun - Number of seconds to Run

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

Throws:

IOException - If an exception occurred.

RecordsWriterTime

void RecordsWriterTime(Worker writer,
 long secondsToRun,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time,
 WriteRequestsLogger logger)
                throws IOException

Writer benchmarking by continuously writing data records for specific time duration. sync is invoked after writing records for given time.

Parameters:

writer - Writer Descriptor

secondsToRun - Number of seconds to Run

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

logger - log write requests

Throws:

IOException - If an exception occurred.

RecordsWriterTimeSync

void RecordsWriterTimeSync(Worker writer,
 long secondsToRun,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time,
 RateController rController)
                    throws IOException

writer benchmarking by continuously writing data records for specific time duration. sync is invoked after writing given set of records.

Parameters:

writer - Writer Descriptor

secondsToRun - Number of seconds to Run

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

rController - Rate Controller

Throws:

IOException - If an exception occurred.

RecordsWriterTimeSync

void RecordsWriterTimeSync(Worker writer,
 long secondsToRun,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time,
 RateController rController,
 WriteRequestsLogger logger)
                    throws IOException

writer benchmarking by continuously writing data records for specific time duration. sync is invoked after writing given set of records.

Parameters:

writer - Writer Descriptor

secondsToRun - Number of seconds to Run

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

rController - Rate Controller

logger - log write requests

Throws:

IOException - If an exception occurred.

RecordsWriterRW

void RecordsWriterRW(Worker writer,
 long recordsCount,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time,
 RateController rController)
              throws IOException

Write given number of records. No Writer Benchmarking is performed But start time is included in the data written.

Parameters:

writer - Writer Descriptor

recordsCount - Records count

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

rController - Rate Controller

Throws:

IOException - If an exception occurred.

RecordsWriterRW

void RecordsWriterRW(Worker writer,
 long recordsCount,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time,
 RateController rController,
 WriteRequestsLogger logger)
              throws IOException

Write given number of records. No Writer Benchmarking is performed But start time is included in the data written.

Parameters:

writer - Writer Descriptor

recordsCount - Records count

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

rController - Rate Controller

logger - log write requests

Throws:

IOException - If an exception occurred.

RecordsWriterTimeRW

void RecordsWriterTimeRW(Worker writer,
 long secondsToRun,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time,
 RateController rController)
                  throws IOException

Writing data records for specific time duration. No Writer Benchmarking is performed But start time is included in the data written.

Parameters:

writer - Writer Descriptor

secondsToRun - Number of seconds to Run

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

rController - Rate Controller

Throws:

IOException - If an exception occurred.

RecordsWriterTimeRW

void RecordsWriterTimeRW(Worker writer,
 long secondsToRun,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time,
 RateController rController,
 WriteRequestsLogger logger)
                  throws IOException

Writing data records for specific time duration. No Writer Benchmarking is performed But start time is included in the data written.

Parameters:

writer - Writer Descriptor

secondsToRun - Number of seconds to Run

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

rController - Rate Controller

logger - log write requests

Throws:

IOException - If an exception occurred.

RecordsWriterRO

void RecordsWriterRO(Worker writer,
 long recordsCount,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time,
 RateController rController)
              throws IOException

Write given number of records. No Writer Benchmarking is performed.

Parameters:

writer - Writer Descriptor

recordsCount - Records count

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

rController - Rate Controller

Throws:

IOException - If an exception occurred.

RecordsWriterRO

void RecordsWriterRO(Worker writer,
 long recordsCount,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time,
 RateController rController,
 WriteRequestsLogger logger)
              throws IOException

Write given number of records. No Writer Benchmarking is performed.

Parameters:

writer - Writer Descriptor

recordsCount - Records count

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

rController - Rate Controller

logger - log write requests

Throws:

IOException - If an exception occurred.

RecordsWriterTimeRO

void RecordsWriterTimeRO(Worker writer,
 long secondsToRun,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time,
 RateController rController)
                  throws IOException

Writing data records for specific time duration. No Writer Benchmarking is performed.

Parameters:

writer - Writer Descriptor

secondsToRun - Number of seconds to Run

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

rController - Rate Controller

Throws:

IOException - If an exception occurred.

RecordsWriterTimeRO

void RecordsWriterTimeRO(Worker writer,
 long secondsToRun,
 DataType<T> dType,
 T data,
 int size,
 io.time.Time time,
 RateController rController,
 WriteRequestsLogger logger)
                  throws IOException

Writing data records for specific time duration. No Writer Benchmarking is performed.

Parameters:

writer - Writer Descriptor

secondsToRun - Number of seconds to Run

dType - Data Type interface

data - data to write

size - size of the data

time - time interface

rController - Rate Controller

logger - log write requests

Throws:

IOException - If an exception occurred.