ParallelQuerySet
ParallelQuerySet
ParallelQuerySet(client: Connector, dry_run: bool = False)
Bases: ParallelQuery
Parallel and Batch Set Multi-Querier for ApertureDB This class provides the mechanism to run multiple queries over a single csv. Per-query actions are done by ParallelQuery.
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
client | Connector | The ApertureDB Connector | required |
dry_run | bool | If True, no queries are executed. Defaults to False. | False |
do_batch
do_batch(client: Connector, batch_start: int, data: List[Tuple[Commands, Blobs]]) -> None
This is an override of ParallelQuery.do_batch.
This is the per-worker function which is the entry-point to a unit of work.
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
client | Connector | The ApertureDB Connector | required |
data | List[Tuple[Query, Blobs]] | A list of tuples, each containing a list of commands and a list of blobs | required |