The inserter Module

compute(how, row)[source]

class Inserter(domain, root_table_name, reader: DataReader, connections, page_size=1000)[source]

prepare(name, table)[source]

read_batch()[source]

import_file(limit=None, log_step=1000000) → int[source]

push(batch)[source]

static drilldown(connection, sql: str, records: list)[source]

get_autocommit()[source]

log_progress()[source]

Batch()[source]

Table(*args, **kwargs)[source]

timer(context: str)[source]

get_thread_timing(context: str) → float[source]

get_timings(context: str) → List[float][source]

get_cumulative_timing(context: str)[source]

stamp_time(context: str)[source]

get_timestamp(context: str, default=0)[source]

reset_timer()[source]