Skip to main content

ParallelQuerySet

ParallelQuerySet Objects​

class ParallelQuerySet(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.

Arguments:

  • client Connector - The ApertureDB Connector
  • dry_run bool, optional - If True, no queries are executed. Defaults to False.

do_batch​

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

Arguments:

  • client Connector - The ApertureDB Connector
  • data List[Tuple[Query, Blobs]] - A list of tuples, each containing a list of commands and a list of blobs