Apache Pig 转义列名称

Question

我正在阅读 Parquet 登录 PIG。日志架构包含嵌套在字段 USER 下的字段 FULL。由于 FULL 是 Pig 中的关键字，因此我无法加载该文件。 Pig 给出编译时错误。没有办法转义这样的字段名。更改模式中的列名真的很不利。这就是我用来加载

user_parquet = LOAD 'test' USING org.apache.parquet.pig.ParquetLoader();
user_normalized = FOREACH user_parquet GENERATE ..... USER.FULL as user_full ...

我尝试使用 \, ``, '' 进行转义，但 none 成功了！

Answer 1

基本上我通过使用字段编号而不是字段名称引用字段来解决问题：-

user_parquet = LOAD 'test' USING org.apache.parquet.pig.ParquetLoader();
user_normalized = FOREACH user_parquet GENERATE ..... USER.[=10=] as user_full ...

Pig，与任何其他语言一样，如果用作变量名，则无法转义关键字。

Apache Pig 转义列名称

Apache Pig escape column name

apache-pig