Движок таблицы YTsaurus

Движок таблицы для импорта данных из кластера YTsaurus.

Движок таблицы YTsaurus позволяет импортировать данные из кластера YTsaurus.

​

Создание таблицы

    CREATE TABLE [IF NOT EXISTS] [db.]table_name
    (
        name1 [type1],
        name2 [type2], ...
    ) ENGINE = YTsaurus('http_proxy_url', 'cypress_path', 'oauth_token')

Это экспериментальная возможность, которая в будущих релизах может измениться обратно несовместимым образом. Включите использование движка таблицы YTsaurus с помощью настройки allow_experimental_ytsaurus_table_engine.

Для этого выполните:

SET allow_experimental_ytsaurus_table_engine = 1.

Параметры движка

• http_proxy_url — URL HTTP-прокси YTsaurus.
• cypress_path — путь Cypress к источнику данных.
• oauth_token — токен OAuth.

​

Пример использования

Показан запрос на создание таблицы YTsaurus:

Query

SHOW CREATE TABLE yt_saurus;

Response

CREATE TABLE yt_saurus
(
    `a` UInt32,
    `b` String
)
ENGINE = YTsaurus('http://localhost:8000', '//tmp/table', 'password')

Чтобы получить данные из таблицы, выполните:

Query

SELECT * FROM yt_saurus;

Response

 ┌──a─┬─b──┐
 │ 10 │ 20 │
 └────┴────┘

​

Типы данных

​

Примитивные типы данных

Тип данных YTsaurus	Тип данных ClickHouse
int8	Int8
int16	Int16
int32	Int32
int64	Int64
uint8	UInt8
uint16	UInt16
uint32	UInt32
uint64	UInt64
float	Float32
double	Float64
boolean	Bool
string	String
utf8	String
json	JSON
yson(type_v3)	JSON
uuid	UUID
date32	Date(пока не поддерживается)
datetime64	Int64
timestamp64	Int64
interval64	Int64
date	Date(пока не поддерживается)
datetime	DateTime
timestamp	DateTime64(6)
interval	UInt64
any	String
null	Nothing
void	Nothing
T при required = False	Nullable(T)

​

Составные типы

Тип данных YTsaurus	Тип данных ClickHouse
decimal	Decimal
optional	Nullable
list	Array
struct	NamedTuple
tuple	Tuple
variant	Variant
dict	`Array(Tuple(…))
tagged	T

См. также

• табличная функция ytsaurus
• схема данных YTsaurus
• типы данных YTsaurus