1

pig UDF のすべてのマッパーが使用するファイルに mapDB を追加したいと考えています。この mapDB オブジェクトを 1 回だけセットアップするにはどうすればよいですか? pig udf がインスタンス化されたときに一度だけ呼び出される関数はありますか?

ありがとう。

4

1 に答える 1

1

pig では、udf がレコードのすべての行に対して呼び出されるように EVALFUNC を拡張する必要があります。

evalfunc を拡張したクラスは pig-script の先頭に定義することでインスタンス化できます。

ex_arg my.udfs.Extract('true'); を定義します。

これにより、クラスがインスタンス化されます。

于 2015-04-30T17:30:51.757 に答える