Package io.sbk.api

Interface DataReader<T>

All Known Subinterfaces:
AsyncReader<T>, DataRecordsReader<T>, Reader<T>
All Known Implementing Classes:
AbstractCallbackReader
public sealed interface DataReader<T> permits AbstractCallbackReader<T>, DataRecordsReader<T>
Interface for Basic Data Readers.

  • Method Details

    • close

      void close() throws IOException
      ß Close the Reader.
      Throws:
      IOException - If an exception occurred.

    • RecordsReader

      void RecordsReader(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time) throws EOFException, IOException
      Benchmarking reader by reading given number of records.
      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

      void RecordsReader(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time, ReadRequestsLogger logger) throws EOFException, IOException
      Benchmarking reader by reading given number of records.
      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

      void RecordsReaderRW(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time) throws EOFException, IOException
      Benchmarking reader by reading given number of records. used while another writer is writing the data.
      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

      void RecordsReaderRW(Worker reader, long recordsCount, DataType<T> dType, io.time.Time time, ReadRequestsLogger logger) throws EOFException, IOException
      Benchmarking reader by reading given number of records. used while another writer is writing the data.
      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.

    • RecordsTimeReader

      void RecordsTimeReader(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time) throws EOFException, IOException
      Benchmarking reader by reading events/records for specific time duration.
      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

      void RecordsTimeReader(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time, ReadRequestsLogger logger) throws EOFException, IOException
      Benchmarking reader by reading events/records for specific time duration.
      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

      void RecordsTimeReaderRW(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time) throws EOFException, IOException
      Benchmarking reader by reading events/records for specific time duration. used while another writer is writing the data.
      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

      void RecordsTimeReaderRW(Worker reader, long secondsToRun, DataType<T> dType, io.time.Time time, ReadRequestsLogger logger) throws EOFException, IOException
      Benchmarking reader by reading events/records for specific time duration. used while another writer is writing the data.
      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.

    • RecordsReaderRateControl

      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.
      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

      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.
      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

      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.
      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

      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.
      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.

    • RecordsTimeReaderRateControl

      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.
      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

      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.
      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

      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.
      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

      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.
      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.