pyflink JDBC Postgresql Каталог выдаёт ошибки для типа данных UUID, как обрабатывать тип данных uuid в API таблиц Flink?

Question

pyflink JDBC Postgresql Каталог выдаёт ошибки для типа данных UUID, как обрабатывать тип данных uuid в API таблиц Flink?

Каталог API таблиц Python Apache Flink 1.11.0: postgresql

Чтение и запись данных из таблиц каталога postgresql, которые содержат столбцы с типом данных UUID через API таблиц, выбрасывая тип данных UUID unsupportedOperatorException.

Как обрабатывать данные UUID в pyFlink?

0

postgresql apache-flink pyflink flink-table-api

Источник

user10975620 18 окт '20 в 07:33

2 ответа

Другие вопросы по тегам postgresql apache-flink pyflink flink-table-api

user10975620 06 ноя '20 в 07:17 2020-11-06 07:17 · Answer 1 · 2020-11-06 07:17

Похоже, что пока нет элегантного способа обрабатывать UUID Postgres с места в карьер, но это то, что будет рассмотрено после завершения доработки системы типов Table API. Я нашел JIRA для того же: https://issues.apache.org/jira/browse/FLINK-19869

0

Источник

user10975620 06 ноя '20 в 07:17

user12728802 21 окт '20 в 05:40 2020-10-21 05:40 · Answer 2 · 2020-10-21 05:40

Я мало что знаю о системе типов PostgreSQL. Тип данных UUID похож на строку? Тип, поддерживаемый PyFlink, в основном такой же, как и тип таблицы Flink. Для получения дополнительной информации вы можете обратиться к документу [1]

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/python/table-api-users-guide/python_types.html