Flink SQL Bigint 数据写入 Hive 表类型转换指南
当使用 Flink SQL 将数据写入 Hive 表的时候,要确保数据类型的匹配。在 Flink SQL 中,bigint 对应的是 Java 中的 Long 类型,而在 Hive 中,bigint 对应的是 Java 中的 BigInteger 类型。
因此,如果要将 Flink SQL 中的 bigint 类型写入 Hive 的 bigint 类型字段,需要确保数据类型的匹配。可以使用 CAST 函数将 Flink SQL 中的 bigint 类型转换为 Hive 中的 bigint 类型,例如:
INSERT INTO hive_table (bigint_column)
SELECT CAST(bigint_column AS BIGINT)
FROM flink_table;
这样就可以将 Flink SQL 中的 bigint 类型数据写入 Hive 的 bigint 类型字段了。请注意,这里的 CAST 函数用于类型转换,确保数据类型的匹配。
原文地址: https://www.cveoy.top/t/topic/lJMS 著作权归作者所有。请勿转载和采集!