PostgreSQL → Parquet
Datatypes conversion mapping when exporting from PostgreSQL (--connectiontype pgsql) to Parquet format.
| Source | PostgreSQL (pgsql) |
| Format | Parquet |
| FastBCP | 0.32.2.0 |
| Test Status | PASS (NotNull + Nullable) |
info
See also PostgreSQL COPY for the COPY protocol variant (--connectiontype pgcopy), which produces identical type mappings.
Parquet Schema: testdatatypes_notnull
| name | physical_type | converted_type | logical_type |
|---|---|---|---|
| col_bigint | INT64 | INT_64 | IntType(bitWidth=64, isSigned=1) |
| col_integer | INT32 | INT_32 | IntType(bitWidth=32, isSigned=1) |
| col_smallint | INT32 | INT_16 | IntType(bitWidth=16, isSigned=1) |
| col_boolean | BOOLEAN | — | — |
| col_numeric | INT64 | DECIMAL | DecimalType(scale=2, precision=18) |
| col_real | FLOAT | — | — |
| col_double_precision | DOUBLE | — | — |
| col_money | FIXED_LEN_BYTE_ARRAY | DECIMAL | DecimalType(scale=4, precision=19) |
| col_date | INT32 | DATE | — |
| col_time | INT32 | TIME_MILLIS | TimeType(isAdjustedToUTC=0, unit=MILLIS) |
| col_timestamp | INT64 | TIMESTAMP_MILLIS | — |
| col_timestamptz | BYTE_ARRAY | UTF8 | StringType() |
| col_interval | FIXED_LEN_BYTE_ARRAY | INTERVAL | — |
| col_char | BYTE_ARRAY | UTF8 | StringType() |
| col_varchar | BYTE_ARRAY | UTF8 | StringType() |
| col_text | BYTE_ARRAY | UTF8 | StringType() |
| col_bytea | BYTE_ARRAY | — | — |
| col_uuid | BYTE_ARRAY | UTF8 | StringType() |
| col_json | BYTE_ARRAY | UTF8 | StringType() |
| col_jsonb | BYTE_ARRAY | — | — |
| col_xml | BYTE_ARRAY | UTF8 | StringType() |
| col_inet | BYTE_ARRAY | UTF8 | StringType() |
| col_cidr | BYTE_ARRAY | UTF8 | StringType() |
| col_macaddr | BYTE_ARRAY | UTF8 | StringType() |
| col_point | BYTE_ARRAY | UTF8 | StringType() |
| col_line | BYTE_ARRAY | UTF8 | StringType() |
| col_lseg | BYTE_ARRAY | UTF8 | StringType() |
| col_box | BYTE_ARRAY | UTF8 | StringType() |
| col_path | BYTE_ARRAY | UTF8 | StringType() |
| col_polygon | BYTE_ARRAY | UTF8 | StringType() |
| col_circle | BYTE_ARRAY | UTF8 | StringType() |
| col_int4range | BYTE_ARRAY | UTF8 | StringType() |
| col_int8range | BYTE_ARRAY | UTF8 | StringType() |
| col_numrange | BYTE_ARRAY | UTF8 | StringType() |
| col_tsrange | BYTE_ARRAY | UTF8 | StringType() |
| col_tstzrange | BYTE_ARRAY | UTF8 | StringType() |
| col_daterange | BYTE_ARRAY | UTF8 | StringType() |
| col_bit | BYTE_ARRAY | UTF8 | StringType() |
| col_bit_varying | BYTE_ARRAY | UTF8 | StringType() |
| col_oid | BYTE_ARRAY | UTF8 | StringType() |
| col_int_array | BYTE_ARRAY | UTF8 | StringType() |
Parquet Schema: testdatatypes_nullable
| name | physical_type | converted_type | logical_type |
|---|---|---|---|
| col_bigint | INT64 | INT_64 | IntType(bitWidth=64, isSigned=1) |
| col_integer | INT32 | INT_32 | IntType(bitWidth=32, isSigned=1) |
| col_smallint | INT32 | INT_16 | IntType(bitWidth=16, isSigned=1) |
| col_boolean | BOOLEAN | — | — |
| col_numeric | INT64 | DECIMAL | DecimalType(scale=2, precision=18) |
| col_real | FLOAT | — | — |
| col_double_precision | DOUBLE | — | — |
| col_money | FIXED_LEN_BYTE_ARRAY | DECIMAL | DecimalType(scale=4, precision=19) |
| col_date | INT32 | DATE | — |
| col_time | INT32 | TIME_MILLIS | TimeType(isAdjustedToUTC=0, unit=MILLIS) |
| col_timestamp | INT64 | TIMESTAMP_MILLIS | — |
| col_timestamptz | BYTE_ARRAY | UTF8 | StringType() |
| col_interval | FIXED_LEN_BYTE_ARRAY | INTERVAL | — |
| col_char | BYTE_ARRAY | UTF8 | StringType() |
| col_varchar | BYTE_ARRAY | UTF8 | StringType() |
| col_text | BYTE_ARRAY | UTF8 | StringType() |
| col_bytea | BYTE_ARRAY | — | — |
| col_uuid | BYTE_ARRAY | UTF8 | StringType() |
| col_json | BYTE_ARRAY | UTF8 | StringType() |
| col_jsonb | BYTE_ARRAY | — | — |
| col_xml | BYTE_ARRAY | UTF8 | StringType() |
| col_inet | BYTE_ARRAY | UTF8 | StringType() |
| col_cidr | BYTE_ARRAY | UTF8 | StringType() |
| col_macaddr | BYTE_ARRAY | UTF8 | StringType() |
| col_point | BYTE_ARRAY | UTF8 | StringType() |
| col_line | BYTE_ARRAY | UTF8 | StringType() |
| col_lseg | BYTE_ARRAY | UTF8 | StringType() |
| col_box | BYTE_ARRAY | UTF8 | StringType() |
| col_path | BYTE_ARRAY | UTF8 | StringType() |
| col_polygon | BYTE_ARRAY | UTF8 | StringType() |
| col_circle | BYTE_ARRAY | UTF8 | StringType() |
| col_int4range | BYTE_ARRAY | UTF8 | StringType() |
| col_int8range | BYTE_ARRAY | UTF8 | StringType() |
| col_numrange | BYTE_ARRAY | UTF8 | StringType() |
| col_tsrange | BYTE_ARRAY | UTF8 | StringType() |
| col_tstzrange | BYTE_ARRAY | UTF8 | StringType() |
| col_daterange | BYTE_ARRAY | UTF8 | StringType() |
| col_bit | BYTE_ARRAY | UTF8 | StringType() |
| col_bit_varying | BYTE_ARRAY | UTF8 | StringType() |
| col_oid | BYTE_ARRAY | UTF8 | StringType() |
| col_int_array | BYTE_ARRAY | UTF8 | StringType() |