public static class ReservoirSample.Initial
extends org.apache.pig.EvalFunc<org.apache.pig.data.Tuple>
Modifier and Type | Field and Description |
---|---|
protected datafu.pig.sampling.ScoredTuple.ScoreGenerator |
scoreGen |
Constructor and Description |
---|
ReservoirSample.Initial() |
ReservoirSample.Initial(java.lang.String numSamples) |
Modifier and Type | Method and Description |
---|---|
org.apache.pig.data.Tuple |
exec(org.apache.pig.data.Tuple input) |
protected datafu.pig.sampling.ScoredTuple.ScoreGenerator |
getScoreGenerator() |
allowCompileTimeCalculation, finish, getArgToFuncMapping, getCacheFiles, getInputSchema, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, getSchemaType, getShipFiles, isAsynchronous, outputSchema, progress, setInputSchema, setPigLogger, setReporter, setUDFContextSignature, warn
public ReservoirSample.Initial()
public ReservoirSample.Initial(java.lang.String numSamples)
protected datafu.pig.sampling.ScoredTuple.ScoreGenerator getScoreGenerator()
public org.apache.pig.data.Tuple exec(org.apache.pig.data.Tuple input) throws java.io.IOException
exec
in class org.apache.pig.EvalFunc<org.apache.pig.data.Tuple>
java.io.IOException