1. LOAD - 加载数据：
LOAD 用于将数据从外部源加载到Pig中。语法如下：
alias = LOAD 'input_path' USING loader_function [AS schema];
- alias： 数据的别名，用于在后续的Pig Latin脚本中引用该数据。
- 'input_path'： 外部数据的路径或位置。
- loader_function： 用于指定加载器函数，根据数据的格式选择适当的加载器。例如，PigStorage(',') 表示使用逗号作为字段分隔符的文本加载器。
- [AS schema]： 可选项，用于指定加载数据后的字段模式。
示例：
-- 使用逗号分隔的文本加载数据，并定义字段模式
data = LOAD 'input.txt' USING PigStorage(',') AS (name:chararray, age:int);
2. STORE - 存储数据：
STORE 用于将处理过的数据存储到外部位置。语法如下：
STORE alias INTO 'output_path' [USING store_function];
- alias： 要存储的数据的别名。
- 'output_path'： 存储数据的目标路径或位置。
- [USING store_function]： 可选项，用于指定存储函数，根据需要选择适当的存储器。例如，PigStorage(',') 表示使用逗号分隔的文本存储器。
示例：
-- 将处理过的数据存储到目标位置
STORE result INTO 'output' USING PigStorage(',');
注意事项：
- 加载器（Loader）和存储器（Storer）： 在使用 LOAD 和 STORE 时，需要选择适当的加载器和存储器，以确保正确解析和保存数据。常见的加载器和存储器包括 PigStorage、TextLoader、JsonLoader 等，具体的选择取决于数据的格式和需求。
- 字段模式： 使用 AS 关键字可以指定加载数据时的字段模式，这有助于正确解释数据的结构。
- 路径： LOAD 和 STORE 中的路径可以是本地文件系统路径或Hadoop分布式文件系统（HDFS）路径，具体取决于你的数据存储位置。
通过合理使用 LOAD 和 STORE 操作，你可以在Apache Pig中加载和存储数据，使其能够被后续的数据处理步骤使用。
转载请注明出处：http://www.pingtaimeng.com/article/detail/11086/Apache Pig