Session.create_table()

Session.create_table(
    name: str,
    *,
    data_types: Mapping[ColumnName, DataType] = frozendict({}),
    default_values: Mapping[ColumnName, Constant | None] = frozendict({}),
    keys: AbstractSet[ColumnName] | Sequence[ColumnName] = frozenset({}),
    partitioning: str | None = None,
) → Table

​

Parameters

​

name

​

data_types

​

default_values

​

keys

​

partitioning

• Only non-joined tables are automatically partitioned.
• Tables are automatically partitioned by hashing their key columns. If there are no key columns, all the dictionarized columns are hashed.
• Joined tables can only use a sub-partitioning of the table referencing them.
• Automatic partitioning is done modulo the number of available cores.

>>> from datetime import date
>>> table = session.create_table(
...     "Product",
...     data_types={
...         "Date": "LocalDate",
...         "Product": "String",
...         "Quantity": "double",
...     },
...     keys={"Product", "Date"},
... )
>>> table.head()
Empty DataFrame
Columns: [Quantity]
Index: []
>>> {column_name: table[column_name].data_type for column_name in table}
{'Date': 'LocalDate', 'Product': 'String', 'Quantity': 'double'}
>>> table.keys
('Date', 'Product')