Modifier and Type | Class and Description |
---|---|
static class |
COV.Final
Deprecated.
|
static class |
COV.Initial
Deprecated.
|
static class |
COV.Intermed
Deprecated.
|
EvalFunc.SchemaType
Modifier and Type | Field and Description |
---|---|
protected java.util.Vector<java.lang.String> |
schemaName
Deprecated.
|
log, pigLogger, reporter, returnType
Constructor and Description |
---|
COV()
Deprecated.
|
COV(java.lang.String... schemaName)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected static Tuple |
combine(DataBag values)
Deprecated.
combine results of different data chunk
|
protected static Tuple |
computeAll(DataBag first,
DataBag second)
Deprecated.
compute sum(XY), sum(X), sum(Y) from given data sets
|
DataBag |
exec(Tuple input)
Deprecated.
Function to compute covariance between data sets.
|
java.lang.String |
getFinal()
Deprecated.
Get the final function.
|
java.lang.String |
getInitial()
Deprecated.
Get the initial function.
|
java.lang.String |
getIntermed()
Deprecated.
Get the intermediate function.
|
Schema |
outputSchema(Schema input)
Deprecated.
Report the schema of the output of this UDF.
|
java.lang.String |
toString()
Deprecated.
Function to return argument of constructor as string.
|
allowCompileTimeCalculation, finish, getArgToFuncMapping, getCacheFiles, getInputSchema, getLoadCaster, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, getSchemaType, getShipFiles, isAsynchronous, needEndOfAllInputProcessing, progress, setEndOfAllInput, setInputSchema, setPigLogger, setReporter, setUDFContextSignature, warn
public COV()
public COV(java.lang.String... schemaName)
public DataBag exec(Tuple input) throws java.io.IOException
public java.lang.String toString()
toString
in class java.lang.Object
public java.lang.String getInitial()
Algebraic
getInitial
in interface Algebraic
public java.lang.String getIntermed()
Algebraic
getIntermed
in interface Algebraic
public java.lang.String getFinal()
Algebraic
protected static Tuple combine(DataBag values) throws java.io.IOException
values
- DataBag containing partial results computed on different data chunksoutput
- Tuple containing combined datajava.io.IOException
protected static Tuple computeAll(DataBag first, DataBag second) throws java.io.IOException
first
- DataBag containing first data setsecond
- DataBag containing second data setjava.io.IOException
public Schema outputSchema(Schema input)
EvalFunc
The default implementation interprets the OutputSchema
annotation,
if one is present. Otherwise, it returns null
(no known output schema).
outputSchema
in class EvalFunc<DataBag>
input
- Schema of the inputCopyright © 2007-2017 The Apache Software Foundation