0

Apache Flink 1.11.0 Python 表 API 目录：postgresql

通过 Table API 从包含 UUID 数据类型列的 postgresql 目录表中读取和写入数据，抛出 UUID 数据类型 unsupportedOperatorException。

如何处理 pyFlink 中的 UUID 数据类型？

4

2 回答 2

0

我对 PostgreSQL 的类型系统了解不多。UUID 数据类型是类似于字符串的类型吗？PyFlink 支持的类型与 Flink 的 Table 类型基本一致。具体可以参考文档[1]

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

于 2020-10-21T02:40:43.893 回答
0

看起来目前还没有一种优雅的方式来处理 Postgres UUID，但是一旦 Table API 的类型系统返工完成，就会涉及到这一点。我找到了相同的 JIRA：https ://issues.apache.org/jira/browse/FLINK-19869

于 2020-11-06T04:17:53.413 回答