0

http://www.findnwrite.com/musings/extract-top-n-records-in-each-group-in-hadoophive/に記載されているようにUDFを作成しました

ステートメントを実行した後、「'com.example.hive.udf.Rank' として一時的な関数ランクを作成します。」http://pastebin.com/hHFa9G9Aに示すようにログを取得します

ログを解釈する方法、または関数が正常に作成されたかどうかを知る方法を教えてください。

また、関数ランクを使用してハイブクエリを実行すると、 http://pastebin.com/fP5LnyGGで説明されているように例外が発生します

4

1 に答える 1

1

この問題は解決しました

記事自体のいくつかのバグhttp://www.findnwrite.com/musings/extract-top-n-records-in-each-group-in-hadoophive/

記事内のステートメントを以下のステートメントに置き換えました

1)

Create Rank jar


jar -cf Rank.jar ./com/example/hive/udf/Rank.class

2)

SELECT user, category, value
FROM (
    SELECT user, category, rank(user) as rank, value
    FROM $compTable
    WHERE user is NOT NULL AND AND ctr > 0
    DISTRIBUTE BY user
    SORT BY user, value desc
) a
WHERE rank(user) < 5
ORDER BY user, rank(user)
于 2013-09-17T13:53:18.667 に答える