datafu.pig.random

Class RandInt

java.lang.Object

org.apache.pig.EvalFunc<T>

datafu.pig.util.ContextualEvalFunc<T>

datafu.pig.util.SimpleEvalFunc<java.lang.Integer>

datafu.pig.random.RandInt

@Nondeterministic
public class RandInt
extends SimpleEvalFunc<java.lang.Integer>

Generates a uniformly distributed integer between two bounds.

Nested Class Summary

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

org.apache.pig.EvalFunc.SchemaType

Field Summary

Fields inherited from class org.apache.pig.EvalFunc

log, pigLogger, reporter, returnType

Constructor Summary

Constructors

Constructor and Description
RandInt()

Method Summary

Modifier and Type	Method and Description
java.lang.Integer	call(java.lang.Integer min, java.lang.Integer max)
org.apache.pig.impl.logicalLayer.schema.Schema	outputSchema(org.apache.pig.impl.logicalLayer.schema.Schema input) Override outputSchema so we can verify the input schema at pig compile time, instead of runtime

Methods inherited from class datafu.pig.util.SimpleEvalFunc

exec, getReturnType

Methods inherited from class datafu.pig.util.ContextualEvalFunc

getContextProperties, getInstanceName, getInstanceProperties, onReady, setUDFContextSignature

Methods inherited from class org.apache.pig.EvalFunc

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RandInt

public RandInt()

Method Detail

call

public java.lang.Integer call(java.lang.Integer min,
                              java.lang.Integer max)
                       throws java.io.IOException

Parameters:

min - lower bound for random number

max - upper bound for random number

Returns:

random integer between min and max

Throws:

java.io.IOException - IOException

outputSchema

public org.apache.pig.impl.logicalLayer.schema.Schema outputSchema(org.apache.pig.impl.logicalLayer.schema.Schema input)

Description copied from class: SimpleEvalFunc

Override outputSchema so we can verify the input schema at pig compile time, instead of runtime

Overrides:

outputSchema in class SimpleEvalFunc<java.lang.Integer>

Parameters:

input - input schema

Returns:

call to super.outputSchema in case schema was defined elsewhere