hadoop - PIG 拉丁语 : Output Path based on Field Value

Question

我有一个日志文件，其中包含来自多个域的日志。现在我想对它们进行一些分析并将输出存储在一个名为域的目录中。我在日志中将域作为字段值:

STORE outputlogs INTO 'testpath/DOMAIN/logs USING....

这可能吗？或者我只能将输出存储在硬编码文件路径中吗？

Answer 1

如果域的名称是outputlogs 中的一个字段，那么您可以使用MultiStorage从存钱 jar 。像这样的东西:

STORE outputlogs INTO 'testpath/DOMAIN/logs' 
                 USING MultiStorage('testpath/DOMAIN/logs','0') ;

其中 0 是域的位置字段。