Вариант использования - создание таблицы с параметрами таблицы с помощью API-интерфейса SQLAlchemy.
Для таблицы MySQL, например:
CREATE TABLE t1 (col1 INT, col2 VARCHAR(32))
PARTITION BY HASH(col1);
Что еще следует добавить в следующий пример кода:
from sqlachemy import Table, Metadata, Column, String, Integer
t1 = Table(
't1',
MetaData(),
Column("col1", Integer),
Column("col2", String(32)),
)
Учитывая Presto SQL, я хочу иметь возможность построить таблицу ниже с помощью Alchemy API:
CREATE TABLE t1 (col1 varchar, dt varchar)
WITH (
format = 'JSON',
external_location = 's3a://bucket_name/path/',
partitioned_by = ARRAY['dt']
)
Любые указатели будут полезны, так как я пытаюсь исправить либо SQLAlchemy, либо такой драйвер, как PyHive.