datafu.pig.sampling
Class SimpleRandomSampleWithReplacementElect
java.lang.Object
org.apache.pig.EvalFunc<T>
org.apache.pig.AccumulatorEvalFunc<T>
org.apache.pig.AlgebraicEvalFunc<org.apache.pig.data.DataBag>
datafu.pig.sampling.SimpleRandomSampleWithReplacementElect
- All Implemented Interfaces:
- org.apache.pig.Accumulator<org.apache.pig.data.DataBag>, org.apache.pig.Algebraic
public class SimpleRandomSampleWithReplacementElect
- extends org.apache.pig.AlgebraicEvalFunc<org.apache.pig.data.DataBag>
Select the candidate with the smallest score for each position from the candidates
proposed by SimpleRandomSampleWithReplacementVote
.
- Author:
- ximeng
- See Also:
SimpleRandomSampleWithReplacementVote
Fields inherited from class org.apache.pig.EvalFunc |
log, pigLogger, reporter, returnType |
Method Summary |
java.lang.String |
getFinal()
|
java.lang.String |
getInitial()
|
java.lang.String |
getIntermed()
|
org.apache.pig.impl.logicalLayer.schema.Schema |
outputSchema(org.apache.pig.impl.logicalLayer.schema.Schema input)
|
Methods inherited from class org.apache.pig.AlgebraicEvalFunc |
accumulate, cleanup, getValue |
Methods inherited from class org.apache.pig.AccumulatorEvalFunc |
exec |
Methods inherited from class org.apache.pig.EvalFunc |
finish, getArgToFuncMapping, getCacheFiles, getInputSchema, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, isAsynchronous, progress, setInputSchema, setPigLogger, setReporter, setUDFContextSignature, warn |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
OUTPUT_BAG_NAME_PREFIX
public static final java.lang.String OUTPUT_BAG_NAME_PREFIX
- Prefix for the output bag name.
- See Also:
- Constant Field Values
tupleFactory
public static final org.apache.pig.data.TupleFactory tupleFactory
bagFactory
public static final org.apache.pig.data.BagFactory bagFactory
SimpleRandomSampleWithReplacementElect
public SimpleRandomSampleWithReplacementElect()
getInitial
public java.lang.String getInitial()
- Specified by:
getInitial
in interface org.apache.pig.Algebraic
- Specified by:
getInitial
in class org.apache.pig.AlgebraicEvalFunc<org.apache.pig.data.DataBag>
getIntermed
public java.lang.String getIntermed()
- Specified by:
getIntermed
in interface org.apache.pig.Algebraic
- Specified by:
getIntermed
in class org.apache.pig.AlgebraicEvalFunc<org.apache.pig.data.DataBag>
getFinal
public java.lang.String getFinal()
- Specified by:
getFinal
in interface org.apache.pig.Algebraic
- Specified by:
getFinal
in class org.apache.pig.AlgebraicEvalFunc<org.apache.pig.data.DataBag>
outputSchema
public org.apache.pig.impl.logicalLayer.schema.Schema outputSchema(org.apache.pig.impl.logicalLayer.schema.Schema input)
- Overrides:
outputSchema
in class org.apache.pig.EvalFunc<org.apache.pig.data.DataBag>
Matthew Hayes, Sam Shah