import org.apache.pig.Algebraic; //导入依赖的package包/类
public String getInitial() throws ExecException {
    instantiateFunc(origFSpec);
    if (func instanceof Algebraic) {
        return ((Algebraic) func).getInitial();
    } else {
        int errCode = 2072;
        String msg = "Attempt to run a non-algebraic function"
            + " as an algebraic function";
        throw new ExecException(msg, errCode, PigException.BUG);
    }
}
 

import org.apache.pig.Algebraic; //导入依赖的package包/类
public String getIntermed() throws ExecException {
    instantiateFunc(origFSpec);
    if (func instanceof Algebraic) {
        return ((Algebraic) func).getIntermed();
    } else {
        int errCode = 2072;
        String msg = "Attempt to run a non-algebraic function"
            + " as an algebraic function";
        throw new ExecException(msg, errCode, PigException.BUG);
    }
}
 

import org.apache.pig.Algebraic; //导入依赖的package包/类
public String getFinal() throws ExecException {
    instantiateFunc(origFSpec);
    if (func instanceof Algebraic) {
        return ((Algebraic) func).getFinal();
    } else {
        int errCode = 2072;
        String msg = "Attempt to run a non-algebraic function"
            + " as an algebraic function";
        throw new ExecException(msg, errCode, PigException.BUG);
    }
}
 

import org.apache.pig.Algebraic; //导入依赖的package包/类
/**
 *
 */
private void setupEvalFuncMap() {

    for (String[] aggGroup : aggs) {
        for (String agg : aggGroup) {
            // doing this as a two step process because PigContext.instantiateFuncFromSpec("SUM.Intermediate")
            // fails with class resolution error.
            EvalFunc<?> func = (EvalFunc<?>)PigContext.instantiateFuncFromSpec(agg);
            evalFuncMap.put(agg, func);
            evalFuncMap.put(agg + "Initial", (EvalFunc<?>)PigContext.instantiateFuncFromSpec(((Algebraic)func).getInitial()));
            evalFuncMap.put(agg + "Intermediate", (EvalFunc<?>)PigContext.instantiateFuncFromSpec(((Algebraic)func).getIntermed()));
            evalFuncMap.put(agg + "Final", (EvalFunc<?>)PigContext.instantiateFuncFromSpec(((Algebraic)func).getFinal()));
        }
    }
}
 

import org.apache.pig.Algebraic; //导入依赖的package包/类
private void setupEvalFuncMap() {
    for (String[] aggGroup : aggs) {
        for (String agg : aggGroup) {
            // doing this as a two step process because PigContext.instantiateFuncFromSpec("SUM.Intermediate")
            // fails with class resolution error.
            EvalFunc<?> func = (EvalFunc<?>)PigContext.instantiateFuncFromSpec(agg);
            evalFuncMap.put(agg, func);
            evalFuncMap.put(agg + "Initial", (EvalFunc<?>)PigContext.instantiateFuncFromSpec(((Algebraic)func).getInitial()));
            evalFuncMap.put(agg + "Intermediate", (EvalFunc<?>)PigContext.instantiateFuncFromSpec(((Algebraic)func).getIntermed()));
            evalFuncMap.put(agg + "Final", (EvalFunc<?>)PigContext.instantiateFuncFromSpec(((Algebraic)func).getFinal()));
        }
    }
}
 

import org.apache.pig.Algebraic; //导入依赖的package包/类
public boolean combinable() {
    return (func instanceof Algebraic);
}
 

import org.apache.pig.Algebraic; //导入依赖的package包/类
public AlgFunc(Algebraic f) {
    this.f=f;
}