atoti.Session.read_parquet()

​

Session.read_parquet(path, /, *, client_side_encryption=None, columns=frozendict({}), data_types=frozendict({}), default_values=frozendict({}), keys=frozenset({}), partitioning=None, table_name=None, **kwargs)

>>> import pprint
>>> from atoti_parquet import ParquetLoad
>>> path = test_resources_path / "dates.parquet"
>>> parquet_load = ParquetLoad(path)
>>> data_types = session.tables.infer_data_types(parquet_load)
>>> table = session.create_table("Example", data_types=data_types)
>>> table.load(parquet_load)
>>> pprint.pp(
...     {column_name: table[column_name].data_type for column_name in table}
... )
{'ID': 'long',
 'Date': 'LocalDateTime',
 'Continent': 'String',
 'Country': 'String',
 'City': 'String',
 'Color': 'String',
 'Quantity': 'double',
 'Price': 'double'}
>>> table.row_count
10

• Parameters:
  • client_side_encryption (ClientSideEncryptionConfig | None) – See atoti_parquet.ParquetLoad.client_side_encryption.
  • columns (Mapping [str , ColumnName ]) – See atoti_parquet.ParquetLoad.columns.
  • data_types (Mapping *[*ColumnName , DataType ]) – See create_table()’s data_types.
  • default_values (Mapping *[*ColumnName , Constant | None ]) – See create_table()’s default_values.
  • keys (AbstractSet *[*ColumnName ] | Sequence *[*ColumnName ]) – See create_table()’s keys.
  • partitioning (str | None) – See create_table()’s partitioning.
  • path (Path | str) – See atoti_parquet.ParquetLoad.path.
  • table_name (TableName | None) – See create_table()’s name.
  • kwargs (Unpack [ _ReadParquetPrivateParameters ])
• Return type: Table