public static class WeightedReservoirSample.Initial extends ReservoirSample.Initial
scoreGen
Constructor and Description |
---|
WeightedReservoirSample.Initial() |
WeightedReservoirSample.Initial(java.lang.String strNumSamples,
java.lang.String strWeightIdx) |
Modifier and Type | Method and Description |
---|---|
protected datafu.pig.sampling.ScoredTuple.ScoreGenerator |
getScoreGenerator() |
exec
allowCompileTimeCalculation, finish, getArgToFuncMapping, getCacheFiles, getInputSchema, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, getSchemaType, getShipFiles, isAsynchronous, outputSchema, progress, setInputSchema, setPigLogger, setReporter, setUDFContextSignature, warn
public WeightedReservoirSample.Initial()
public WeightedReservoirSample.Initial(java.lang.String strNumSamples, java.lang.String strWeightIdx)
protected datafu.pig.sampling.ScoredTuple.ScoreGenerator getScoreGenerator()
getScoreGenerator
in class ReservoirSample.Initial