Hive - внутри функции UDF можно получить доступ к данным таблицы Hive.

Я создал образец TestUDF.

import org.apache.hadoop.hive.ql.exec.Description;
import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.*;
@Description (
    name="test",
    value="returns the sum of two double values",
    extended="SELECT test(a, b) from foo limit 1;"
)

public class TestUDF extends UDF {

    public String evaluate(Text text) {
            if(text == null) 
                return null;

            return text.toString();
    }

    // one time i want to read hive table data and access inside evaluate function
}

Здесь я хочу получить доступ к данным таблицы улья и выполнить некоторые операции. Можно получить доступ к таблице улья внутри функции UDF.

0 ответов

Другие вопросы по тегам