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