Interface RecordSourceReader

All Known Subinterfaces:
FileSourceReader
All Known Implementing Classes:
CsvDirectoryAdapter, H2Adapter, JdbcRecordAdapter, PostgreSqlAdapter, XlsxWorkbookAdapter

public interface RecordSourceReader
Abstraction for reading raw records from a source backend.

Implementations are free to map sourceName to a table name, CSV file, worksheet name, API endpoint, etc.

  • Method Summary

    Modifier and Type
    Method
    Description
    read(String sourceName, Map<String,String> equalsFilter)
    Reads rows from a backend object with an equality filter.
  • Method Details

    • read

      List<Map<String,Object>> read(String sourceName, Map<String,String> equalsFilter) throws Exception
      Reads rows from a backend object with an equality filter.
      Parameters:
      sourceName - backend-specific source object name
      equalsFilter - key/value equality filter (column -> required value)
      Returns:
      list of rows as column/value maps
      Throws:
      Exception - on backend access failures