COV
@Deprecated public class COV extends EvalFunc<DataBag> implements Algebraic, Serializable
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 Vector<String> |
schemaName
Deprecated.
|
log, pigLogger, reporter, returnType
Constructor and Description |
---|
COV()
Deprecated.
|
COV(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.
|
String |
getFinal()
Deprecated.
Get the final function.
|
String |
getInitial()
Deprecated.
Get the initial function.
|
String |
getIntermed()
Deprecated.
Get the intermediate function.
|
Schema |
outputSchema(Schema input)
Deprecated.
Report the schema of the output of this UDF.
|
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(String... schemaName)
public DataBag exec(Tuple input) throws IOException
exec
in class EvalFunc<DataBag>
input
- input tuple which contains data sets.output
- output dataBag which contain covariance between each pair of data sets.IOException
public String toString()
public String getInitial()
Algebraic
getInitial
in interface Algebraic
public String getIntermed()
Algebraic
getIntermed
in interface Algebraic
public String getFinal()
Algebraic
protected static Tuple combine(DataBag values) throws IOException
values
- DataBag containing partial results computed on different data chunksoutput
- Tuple containing combined dataIOException
protected static Tuple computeAll(DataBag first, DataBag second) throws IOException
first
- DataBag containing first data setsecond
- DataBag containing second data setIOException
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