datafu.pig.sampling

Class ReservoirSample.Initial

java.lang.Object

org.apache.pig.EvalFunc<org.apache.pig.data.Tuple>

datafu.pig.sampling.ReservoirSample.Initial

Direct Known Subclasses:

WeightedReservoirSample.Initial

Enclosing class:

ReservoirSample

public static class ReservoirSample.Initial
extends org.apache.pig.EvalFunc<org.apache.pig.data.Tuple>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pig.EvalFunc

org.apache.pig.EvalFunc.SchemaType

Field Summary

Fields

Modifier and Type	Field and Description
protected datafu.pig.sampling.ScoredTuple.ScoreGenerator	scoreGen

Fields inherited from class org.apache.pig.EvalFunc

log, pigLogger, reporter, returnType

Constructor Summary

Constructors

Constructor and Description
Initial()
Initial(java.lang.String numSamples)

Method Summary

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()

Methods inherited from class org.apache.pig.EvalFunc

allowCompileTimeCalculation, finish, getArgToFuncMapping, getCacheFiles, getInputSchema, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, getSchemaType, getShipFiles, isAsynchronous, outputSchema, progress, setInputSchema, setPigLogger, setReporter, setUDFContextSignature, warn

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

scoreGen

protected datafu.pig.sampling.ScoredTuple.ScoreGenerator scoreGen

Constructor Detail

Initial

public Initial()

Initial

public Initial(java.lang.String numSamples)

Method Detail

getScoreGenerator

protected datafu.pig.sampling.ScoredTuple.ScoreGenerator getScoreGenerator()

exec

public org.apache.pig.data.Tuple exec(org.apache.pig.data.Tuple input)
                               throws java.io.IOException

Specified by:

exec in class org.apache.pig.EvalFunc<org.apache.pig.data.Tuple>

Throws:

java.io.IOException