fraudtwin.iter_partition_rows#

fraudtwin.iter_partition_rows(run_dir, *, shard_id=None, columns=None)[source][source]#

Read scale chunks one file at a time, keeping reader memory bounded.

Return type:

Iterator[dict[str, Any]]

Parameters:
  • run_dir (str | Path)

  • shard_id (str | None)

  • columns (list[str] | None)