hadoop - 如何设置 Pig STORE 命令的输出目录？

Question

我通过 Azure HDInsight 使用 Pig。我可以提交以 STORE 结尾的查询，如下所示：

STORE Ordered INTO 'results' USING PigStorage(',');

这有效，将输出存储在目录中/user/hdp/results/。但是我想控制输出目录。两个我都试过了...

STORE Ordered INTO '/myOutDir/results' USING PigStorage(',');

和

STORE Ordered INTO 'wasb:///myOutDir/results' USING PigStorage(',');

这些都不起作用。他们都产生这个错误：

Ordered was unexpected at this time.

我的问题是，我可以控制 Store 命令的输出目录吗？还是必须进入用户目录？

Answer 1

使用如下输出路径

wasb[s]://<BlobStorageContainerName>@<StorageAccountName>.blob.core.windows.net/<path>

如果您的输出路径/example/data/sample.log然后使用

wasb://mycontainer@mystorageaccount.blob.core.windows.net/example/data/sample.log
wasb:///example/data/sample.log

我希望这可以帮助你。:-)

Answer 2

如果要使用参数设置输出，可以这样做：

 STORE Ordered INTO '$myOutDir/results' USING...

然后使用以下命令运行您的脚本：

 pig -param myOutDir=/blablabla/... myScript.pig

注意：您还可以为参数设置默认值，在脚本顶部添加：

%default myOutDir '/blablabla/...'

希望这有帮助，祝你好运:)