The pg_export_parquet Module

A command line utility to export results of SQL query as Parquet files

result_set(conn: connection, sql: str, cursor_name: str, batch_size: int)

index_of(text: str, token: str)

class PgPqBase(cnxn: connection, sql: str, destination: str)

setup_schema()

static type_pg2pq(vtype: str)

metadata_sql() → str

get_metadata() → List[Tuple]

set_partitioning(columns: List[str])

abstract export()

classmethod run()

classmethod export_sql(arguments, sql)

classmethod export_table(arguments, table: str)

classmethod export_schema(arguments)

class PgPqSingleQuery(cnxn: connection, sql: str, destination: str, mode: str, schema: Optional[Schema] = None)

static normalize_value(v)

transform(row: Dict) → Dict

set_partitioning(columns: List[str], values: Optional[List] = None)

export()

batch(data: List[Dict])

batches()

class PgPqPartitionedQuery(cnxn: connection, sql: str, destination: str, partition: List[str])

static qualify_column(sql: str, column: str, idx_select: int)

set_partition_values()

set_partitioning(partition: List[str])

export()