pw.io.sqlite

pw.io.sqlite.read(path, table_name, schema, *, autocommit_duration_ms=1500, debug_data=None)

sourceReads a table from a rowid table in SQLite database.

  • Parameters
    • path (PathLike | str) – Path to the database file.
    • table_name (str) – Name of the table in the database to be read.
    • schema (type[Schema]) – Schema of the resulting table.
    • autocommit_duration_ms (int | None) – The maximum time between two commits. Every autocommit_duration_ms milliseconds, the updates received by the connector are committed and pushed into Pathway’s computation graph.
  • Returns
    Table – The table read.