Package io.sbk.api

Interface DataRecordsReader<T>

All Superinterfaces:

DataReader<T>

All Known Subinterfaces:

AsyncReader<T>, Reader<T>

public sealed interface DataRecordsReader<T>
extends DataReader<T>
permits AsyncReader<T>, Reader<T>

Interface for Data Record Readers.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	DataRecordsReader.RecordTime<T>	interface RecordTime.
static interface	DataRecordsReader.RecordTimeRequests<T>

Method Summary

Modifier and Type	Method	Description
default void	genericRecordsReader(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time, DataRecordsReader.RecordTime<T> recordTime)	Benchmarking reader by reading given number of records.
default void	genericRecordsReader(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time, DataRecordsReader.RecordTimeRequests<T> recordTime, ReadRequestsLogger logger)	Benchmarking reader by reading given number of records.
default void	genericRecordsReaderRateControl(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time, RateController rController, DataRecordsReader.RecordTime<T> recordTime)	Benchmarking reader with Rate controlled.
default void	genericRecordsReaderRateControl(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time, RateController rController, DataRecordsReader.RecordTimeRequests<T> recordTime, ReadRequestsLogger logger)	Benchmarking reader with Rate controlled.
default void	genericRecordsTimeReader(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time, DataRecordsReader.RecordTime<T> recordTime)	Benchmarking reader by reading events/records for specific time duration.
default void	genericRecordsTimeReader(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time, DataRecordsReader.RecordTimeRequests<T> recordTime, ReadRequestsLogger logger)	Benchmarking reader by reading events/records for specific time duration.
default void	genericRecordsTimeReaderRateControl(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time, RateController rController, DataRecordsReader.RecordTime<T> recordTime)	Benchmarking reader by reading events/records with Rate Controls.
default void	genericRecordsTimeReaderRateControl(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time, RateController rController, DataRecordsReader.RecordTimeRequests<T> recordTime, ReadRequestsLogger logger)	Benchmarking reader by reading events/records with Rate Controls.
void	recordRead(DataType<T> dType, int size, io.time.Time time, Status status, io.perl.api.PerlChannel perlChannel)	Record the single or multiple reads performance statistics.
void	recordRead(DataType<T> dType, int size, io.time.Time time, Status status, io.perl.api.PerlChannel perlChannel, int id, ReadRequestsLogger logger)	Record the single or multiple reads performance statistics.
void	recordReadTime(DataType<T> dType, int size, io.time.Time time, Status status, io.perl.api.PerlChannel perlChannel)	Record the single or multiple reads performance statistics along with the starting time in the data.
void	recordReadTime(DataType<T> dType, int size, io.time.Time time, Status status, io.perl.api.PerlChannel perlChannel, int id, ReadRequestsLogger logger)	Record the single or multiple reads performance statistics along with the starting time in the data.
default void	RecordsReader(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time)	Default implementation for benchmarking reader by reading given number of records.
default void	RecordsReader(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time, ReadRequestsLogger logger)	Default implementation for benchmarking reader by reading given number of records.
default void	RecordsReaderRateControl(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time, RateController rController)	Benchmarking reader by reading given number of records with Rate controlled.
default void	RecordsReaderRateControl(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time, RateController rController, ReadRequestsLogger logger)	Benchmarking reader by reading given number of records with Rate controlled.
default void	RecordsReaderRW(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time)	Default implementation for benchmarking reader by reading given number of records.
default void	RecordsReaderRW(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time, ReadRequestsLogger logger)	Default implementation for benchmarking reader by reading given number of records.
default void	RecordsReaderRWRateControl(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time, RateController rController)	Benchmarking reader by reading given number of records with Rate controlled.
default void	RecordsReaderRWRateControl(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time, RateController rController, ReadRequestsLogger logger)	Benchmarking reader by reading given number of records with Rate controlled.
default void	RecordsTimeReader(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time)	Default implementation for benchmarking reader by reading events/records for specific time duration.
default void	RecordsTimeReader(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time, ReadRequestsLogger logger)	Default implementation for benchmarking reader by reading events/records for specific time duration.
default void	RecordsTimeReaderRateControl(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time, RateController rController)	Benchmarking reader by reading events/records for specific time duration with Rate controlled.
default void	RecordsTimeReaderRateControl(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time, RateController rController, ReadRequestsLogger logger)	Benchmarking reader by reading events/records for specific time duration with Rate controlled.
default void	RecordsTimeReaderRW(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time)	Default implementation for benchmarking reader by reading events/records for specific time duration.
default void	RecordsTimeReaderRW(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time, ReadRequestsLogger logger)	Default implementation for benchmarking reader by reading events/records for specific time duration.
default void	RecordsTimeReaderRWRateControl(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time, RateController rController)	Benchmarking reader by reading events/records for specific time duration with Rate controlled.
default void	RecordsTimeReaderRWRateControl(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time, RateController rController, ReadRequestsLogger logger)	Benchmarking reader by reading events/records for specific time duration with Rate controlled.

Methods inherited from interface io.sbk.api.DataReader

close

Method Details

recordRead

void recordRead(DataType<T> dType,
 int size,
 io.time.Time time,
 Status status,
 io.perl.api.PerlChannel perlChannel)
         throws EOFException,
IOException

Record the single or multiple reads performance statistics.

Parameters:

dType - dataType

size - size of data in bytes

time - time interface

status - read status to return; Status

perlChannel - to call for benchmarking

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

recordRead

void recordRead(DataType<T> dType,
 int size,
 io.time.Time time,
 Status status,
 io.perl.api.PerlChannel perlChannel,
 int id,
 ReadRequestsLogger logger)
         throws EOFException,
IOException

Record the single or multiple reads performance statistics.

Parameters:

dType - dataType

size - size of data in bytes

time - time interface

status - read status to return; Status

perlChannel - to call for benchmarking

id - reader id

logger - Read Request logger

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

recordReadTime

void recordReadTime(DataType<T> dType,
 int size,
 io.time.Time time,
 Status status,
 io.perl.api.PerlChannel perlChannel)
             throws EOFException,
IOException

Record the single or multiple reads performance statistics along with the starting time in the data.

Parameters:

dType - dataType

size - size of data in bytes

time - time interface

status - read status to return; Status

perlChannel - to call for benchmarking

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

recordReadTime

void recordReadTime(DataType<T> dType,
 int size,
 io.time.Time time,
 Status status,
 io.perl.api.PerlChannel perlChannel,
 int id,
 ReadRequestsLogger logger)
             throws EOFException,
IOException

Record the single or multiple reads performance statistics along with the starting time in the data.

Parameters:

dType - dataType

size - size of data in bytes

time - time interface

status - read status to return; Status

perlChannel - to call for benchmarking

id - reader id

logger - Read Request logger

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

genericRecordsReader

default void genericRecordsReader(Worker reader,
 long recordsCount,
 DataType<T> dType,
 io.time.Time time,
 DataRecordsReader.RecordTime<T> recordTime)
                           throws EOFException,
IOException

Benchmarking reader by reading given number of records.

Parameters:

reader - Worker

recordsCount - long

dType - DataType

time - Time

recordTime - RecordTime

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

genericRecordsReader

default void genericRecordsReader(Worker reader,
 long recordsCount,
 DataType<T> dType,
 io.time.Time time,
 DataRecordsReader.RecordTimeRequests<T> recordTime,
 ReadRequestsLogger logger)
                           throws EOFException,
IOException

Benchmarking reader by reading given number of records.

Parameters:

reader - Worker

recordsCount - long

dType - DataType

time - Time

recordTime - RecordTime

logger - log read requests

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsReader

default void RecordsReader(Worker reader,
 long recordsCount,
 DataType<T> dType,
 io.time.Time time)
                    throws EOFException,
IOException

Default implementation for benchmarking reader by reading given number of records. This method uses the method recordRead(DataType, int, Time, Status, PerlChannel)

Specified by:

RecordsReader in interface DataReader<T>

Parameters:

reader - Reader Descriptor

recordsCount - Records count

dType - dataType

time - time interface

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsReader

default void RecordsReader(Worker reader,
 long recordsCount,
 DataType<T> dType,
 io.time.Time time,
 ReadRequestsLogger logger)
                    throws EOFException,
IOException

Default implementation for benchmarking reader by reading given number of records. This method uses the method recordRead(DataType, int, Time, Status, PerlChannel)

Specified by:

RecordsReader in interface DataReader<T>

Parameters:

reader - Reader Descriptor

recordsCount - Records count

dType - dataType

time - time interface

logger - log read requests

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsReaderRW

default void RecordsReaderRW(Worker reader,
 long recordsCount,
 DataType<T> dType,
 io.time.Time time)
                      throws EOFException,
IOException

Default implementation for benchmarking reader by reading given number of records. This method uses the method recordReadTime(DataType, int, Time, Status, PerlChannel)

Specified by:

RecordsReaderRW in interface DataReader<T>

Parameters:

reader - Reader Descriptor

recordsCount - Records count

dType - dataType

time - time interface

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsReaderRW

default void RecordsReaderRW(Worker reader,
 long recordsCount,
 DataType<T> dType,
 io.time.Time time,
 ReadRequestsLogger logger)
                      throws EOFException,
IOException

Default implementation for benchmarking reader by reading given number of records. This method uses the method recordReadTime(DataType, int, Time, Status, PerlChannel)

Specified by:

RecordsReaderRW in interface DataReader<T>

Parameters:

reader - Reader Descriptor

recordsCount - Records count

dType - dataType

time - time interface

logger - log read requests

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

genericRecordsTimeReader

default void genericRecordsTimeReader(Worker reader,
 long secondsToRun,
 DataType<T> dType,
 io.time.Time time,
 DataRecordsReader.RecordTime<T> recordTime)
                               throws EOFException,
IOException

Benchmarking reader by reading events/records for specific time duration.

Parameters:

reader - Worker

secondsToRun - long

dType - DataType

time - Time

recordTime - RecordTime

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

genericRecordsTimeReader

default void genericRecordsTimeReader(Worker reader,
 long secondsToRun,
 DataType<T> dType,
 io.time.Time time,
 DataRecordsReader.RecordTimeRequests<T> recordTime,
 ReadRequestsLogger logger)
                               throws EOFException,
IOException

Benchmarking reader by reading events/records for specific time duration.

Parameters:

reader - Worker

secondsToRun - long

dType - DataType

time - Time

recordTime - RecordTime

logger - log read requests

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsTimeReader

default void RecordsTimeReader(Worker reader,
 long secondsToRun,
 DataType<T> dType,
 io.time.Time time)
                        throws EOFException,
IOException

Default implementation for benchmarking reader by reading events/records for specific time duration. This method uses the method recordRead(DataType, int, Time, Status, PerlChannel)

Specified by:

RecordsTimeReader in interface DataReader<T>

Parameters:

reader - Reader Descriptor

secondsToRun - Number of seconds to run

dType - dataType

time - time interface

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsTimeReader

default void RecordsTimeReader(Worker reader,
 long secondsToRun,
 DataType<T> dType,
 io.time.Time time,
 ReadRequestsLogger logger)
                        throws EOFException,
IOException

Default implementation for benchmarking reader by reading events/records for specific time duration. This method uses the method recordRead(DataType, int, Time, Status, PerlChannel)

Specified by:

RecordsTimeReader in interface DataReader<T>

Parameters:

reader - Reader Descriptor

secondsToRun - Number of seconds to run

dType - dataType

time - time interface

logger - log read requests

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsTimeReaderRW

default void RecordsTimeReaderRW(Worker reader,
 long secondsToRun,
 DataType<T> dType,
 io.time.Time time)
                          throws EOFException,
IOException

Default implementation for benchmarking reader by reading events/records for specific time duration. This method uses the method recordReadTime(DataType, int, Time, Status, PerlChannel)

Specified by:

RecordsTimeReaderRW in interface DataReader<T>

Parameters:

reader - Reader Descriptor

secondsToRun - Number of seconds to run

dType - dataType

time - time interface

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsTimeReaderRW

default void RecordsTimeReaderRW(Worker reader,
 long secondsToRun,
 DataType<T> dType,
 io.time.Time time,
 ReadRequestsLogger logger)
                          throws EOFException,
IOException

Default implementation for benchmarking reader by reading events/records for specific time duration. This method uses the method recordReadTime(DataType, int, Time, Status, PerlChannel)

Specified by:

RecordsTimeReaderRW in interface DataReader<T>

Parameters:

reader - Reader Descriptor

secondsToRun - Number of seconds to run

dType - dataType

time - time interface

logger - log read requests

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

genericRecordsReaderRateControl

default void genericRecordsReaderRateControl(Worker reader,
 long recordsCount,
 DataType<T> dType,
 io.time.Time time,
 RateController rController,
 DataRecordsReader.RecordTime<T> recordTime)
                                      throws EOFException,
IOException

Benchmarking reader with Rate controlled.

Parameters:

reader - Worker

recordsCount - long

dType - DataType

time - Time

rController - RateController

recordTime - RecordTime

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

genericRecordsReaderRateControl

default void genericRecordsReaderRateControl(Worker reader,
 long recordsCount,
 DataType<T> dType,
 io.time.Time time,
 RateController rController,
 DataRecordsReader.RecordTimeRequests<T> recordTime,
 ReadRequestsLogger logger)
                                      throws EOFException,
IOException

Benchmarking reader with Rate controlled.

Parameters:

reader - Worker

recordsCount - long

dType - DataType

time - Time

rController - RateController

recordTime - RecordTime

logger - log read requests

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsReaderRateControl

default void RecordsReaderRateControl(Worker reader,
 long recordsCount,
 DataType<T> dType,
 io.time.Time time,
 RateController rController)
                               throws EOFException,
IOException

Benchmarking reader by reading given number of records with Rate controlled.

Specified by:

RecordsReaderRateControl in interface DataReader<T>

Parameters:

reader - Reader Descriptor

recordsCount - Records count

dType - dataType

time - time interface

rController - Rate Controller

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsReaderRateControl

default void RecordsReaderRateControl(Worker reader,
 long recordsCount,
 DataType<T> dType,
 io.time.Time time,
 RateController rController,
 ReadRequestsLogger logger)
                               throws EOFException,
IOException

Benchmarking reader by reading given number of records with Rate controlled.

Specified by:

RecordsReaderRateControl in interface DataReader<T>

Parameters:

reader - Reader Descriptor

recordsCount - Records count

dType - dataType

time - time interface

rController - Rate Controller

logger - log read requests

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsReaderRWRateControl

default void RecordsReaderRWRateControl(Worker reader,
 long recordsCount,
 DataType<T> dType,
 io.time.Time time,
 RateController rController)
                                 throws EOFException,
IOException

Benchmarking reader by reading given number of records with Rate controlled. used while another writer is writing the data.

Specified by:

RecordsReaderRWRateControl in interface DataReader<T>

Parameters:

reader - Reader Descriptor

recordsCount - Records count

dType - dataType

time - time interface

rController - Rate Controller

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsReaderRWRateControl

default void RecordsReaderRWRateControl(Worker reader,
 long recordsCount,
 DataType<T> dType,
 io.time.Time time,
 RateController rController,
 ReadRequestsLogger logger)
                                 throws EOFException,
IOException

Benchmarking reader by reading given number of records with Rate controlled. used while another writer is writing the data.

Specified by:

RecordsReaderRWRateControl in interface DataReader<T>

Parameters:

reader - Reader Descriptor

recordsCount - Records count

dType - dataType

time - time interface

rController - Rate Controller

logger - log read requests

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

genericRecordsTimeReaderRateControl

default void genericRecordsTimeReaderRateControl(Worker reader,
 long secondsToRun,
 DataType<T> dType,
 io.time.Time time,
 RateController rController,
 DataRecordsReader.RecordTime<T> recordTime)
                                          throws EOFException,
IOException

Benchmarking reader by reading events/records with Rate Controls.

Parameters:

reader - Worker

secondsToRun - long

dType - DataType

time - Time

rController - RateController

recordTime - RecordTime

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

genericRecordsTimeReaderRateControl

default void genericRecordsTimeReaderRateControl(Worker reader,
 long secondsToRun,
 DataType<T> dType,
 io.time.Time time,
 RateController rController,
 DataRecordsReader.RecordTimeRequests<T> recordTime,
 ReadRequestsLogger logger)
                                          throws EOFException,
IOException

Benchmarking reader by reading events/records with Rate Controls.

Parameters:

reader - Worker

secondsToRun - long

dType - DataType

time - Time

rController - RateController

recordTime - RecordTime

logger - log read requests

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsTimeReaderRateControl

default void RecordsTimeReaderRateControl(Worker reader,
 long secondsToRun,
 DataType<T> dType,
 io.time.Time time,
 RateController rController)
                                   throws EOFException,
IOException

Benchmarking reader by reading events/records for specific time duration with Rate controlled.

Specified by:

RecordsTimeReaderRateControl in interface DataReader<T>

Parameters:

reader - Reader Descriptor

secondsToRun - Number of seconds to run

dType - dataType

time - time interface

rController - Rate Controller

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsTimeReaderRateControl

default void RecordsTimeReaderRateControl(Worker reader,
 long secondsToRun,
 DataType<T> dType,
 io.time.Time time,
 RateController rController,
 ReadRequestsLogger logger)
                                   throws EOFException,
IOException

Benchmarking reader by reading events/records for specific time duration with Rate controlled.

Specified by:

RecordsTimeReaderRateControl in interface DataReader<T>

Parameters:

reader - Reader Descriptor

secondsToRun - Number of seconds to run

dType - dataType

time - time interface

rController - Rate Controller

logger - log read requests

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsTimeReaderRWRateControl

default void RecordsTimeReaderRWRateControl(Worker reader,
 long secondsToRun,
 DataType<T> dType,
 io.time.Time time,
 RateController rController)
                                     throws EOFException,
IOException

Benchmarking reader by reading events/records for specific time duration with Rate controlled. used while another writer is writing the data.

Specified by:

RecordsTimeReaderRWRateControl in interface DataReader<T>

Parameters:

reader - Reader Descriptor

secondsToRun - Number of seconds to run

dType - dataType

time - time interface

rController - Rate Controller

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.

RecordsTimeReaderRWRateControl

default void RecordsTimeReaderRWRateControl(Worker reader,
 long secondsToRun,
 DataType<T> dType,
 io.time.Time time,
 RateController rController,
 ReadRequestsLogger logger)
                                     throws EOFException,
IOException

Benchmarking reader by reading events/records for specific time duration with Rate controlled. used while another writer is writing the data.

Specified by:

RecordsTimeReaderRWRateControl in interface DataReader<T>

Parameters:

reader - Reader Descriptor

secondsToRun - Number of seconds to run

dType - dataType

time - time interface

rController - Rate Controller

logger - log read requests

Throws:

EOFException - If the End of the file occurred.

IOException - If an exception occurred.