org.apache.pig.backend.hadoop.executionengine.tez.plan.udf

Class ReadScalarsTez

java.lang.Object

org.apache.pig.EvalFunc<Object>

org.apache.pig.backend.hadoop.executionengine.tez.plan.udf.ReadScalarsTez

All Implemented Interfaces:

TezInput

public class ReadScalarsTez
extends EvalFunc<Object>
implements TezInput

Nested Class Summary

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

EvalFunc.SchemaType

Field Summary

Fields inherited from class org.apache.pig.EvalFunc

log, pigLogger, reporter, returnType

Constructor Summary

Constructors

Constructor and Description
ReadScalarsTez(String inputKey)

Method Summary

Methods

Modifier and Type	Method and Description
void	addInputsToSkip(Set<String> inputsToSkip) Add to the list of inputs to skip download if already available in vertex cache
void	attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf) Attach the inputs to the operator.
Object	exec(Tuple input) This callback method must be implemented by all subclasses.
String[]	getTezInputs()
void	replaceInput(String oldInputKey, String newInputKey)

Methods inherited from class org.apache.pig.EvalFunc

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadScalarsTez

public ReadScalarsTez(String inputKey)

Method Detail

getTezInputs

public String[] getTezInputs()

Specified by:

getTezInputs in interface TezInput

replaceInput

public void replaceInput(String oldInputKey,
                String newInputKey)

Specified by:

replaceInput in interface TezInput

addInputsToSkip

public void addInputsToSkip(Set<String> inputsToSkip)

Description copied from interface: TezInput

Add to the list of inputs to skip download if already available in vertex cache

Specified by:

addInputsToSkip in interface TezInput

attachInputs

public void attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs,
                org.apache.hadoop.conf.Configuration conf)
                  throws ExecException

Description copied from interface: TezInput

Attach the inputs to the operator. Also ensure reader.next() is called to force fetch the input so that all inputs are fetched and memory released before memory is allocated for outputs

Specified by:

attachInputs in interface TezInput

Parameters:

inputs - available inputs

conf - configuration

Throws:

ExecException

exec

public Object exec(Tuple input)
            throws IOException

Description copied from class: EvalFunc

This callback method must be implemented by all subclasses. This is the method that will be invoked on every Tuple of a given dataset. Since the dataset may be divided up in a variety of ways the programmer should not make assumptions about state that is maintained between invocations of this method.

Specified by:

exec in class EvalFunc<Object>

Parameters:

input - the Tuple to be processed.

Returns:

result, of type T.

Throws:

IOException