org.apache.pig.tools.parameters

Class PreprocessorContext

java.lang.Object

org.apache.pig.tools.parameters.PreprocessorContext

public class PreprocessorContext
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PreprocessorContext.CallableStreamReader Slurp in an entire input stream and close it.

Constructor Summary

Constructors

Constructor and Description
PreprocessorContext(int limit)

Method Summary

Modifier and Type	Method and Description
Map<String,String>	getParamVal()
void	loadParamVal(List<String> params, List<String> paramFiles)
void	paramScopePop()
void	paramScopePush()
boolean	paramval_containsKey(String key)
String	paramval_get(String key)
void	paramval_put(String key, String value)
void	processOrdLine(String key, String val) This method generates value for the specified key by performing substitution if needed within the value first.
void	processOrdLine(String key, String val, Boolean overwrite) This method generates value for the specified key by performing substitution if needed within the value first.
void	processShellCmd(String key, String val) This method generates parameter value by running specified command
void	processShellCmd(String key, String val, Boolean overwrite) This method generates parameter value by running specified command
void	setPigContext(PigContext context)
String	substitute(String line)
String	substitute(String line, String parentKey)
void	validate(String preprocessorCmd)

Methods inherited from class java.lang.Object

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

Constructor Detail

PreprocessorContext

public PreprocessorContext(int limit)

Parameters:

limit - - max number of parameters. Passing smaller number only impacts performance

Method Detail

getParamVal

public Map<String,String> getParamVal()

setPigContext

public void setPigContext(PigContext context)

processShellCmd

public void processShellCmd(String key,
                            String val)
                     throws ParameterSubstitutionException,
                            FrontendException

This method generates parameter value by running specified command

Parameters:

key - - parameter name

val - - string containing command to be executed

Throws:

ParameterSubstitutionException

FrontendException

processOrdLine

public void processOrdLine(String key,
                           String val)
                    throws ParameterSubstitutionException

This method generates value for the specified key by performing substitution if needed within the value first.

Parameters:

key - - parameter name

val - - value supplied for the key

Throws:

ParameterSubstitutionException

paramScopePush

public void paramScopePush()

paramScopePop

public void paramScopePop()

paramval_containsKey

public boolean paramval_containsKey(String key)

paramval_get

public String paramval_get(String key)

paramval_put

public void paramval_put(String key,
                         String value)

processShellCmd

public void processShellCmd(String key,
                            String val,
                            Boolean overwrite)
                     throws ParameterSubstitutionException,
                            FrontendException

This method generates parameter value by running specified command

Parameters:

key - - parameter name

val - - string containing command to be executed

Throws:

ParameterSubstitutionException

FrontendException

validate

public void validate(String preprocessorCmd)
              throws FrontendException

Throws:

FrontendException

processOrdLine

public void processOrdLine(String key,
                           String val,
                           Boolean overwrite)
                    throws ParameterSubstitutionException

This method generates value for the specified key by performing substitution if needed within the value first.

Parameters:

key - - parameter name

val - - value supplied for the key

overwrite - - specifies whether the value should be replaced if it already exists

Throws:

ParameterSubstitutionException

loadParamVal

public void loadParamVal(List<String> params,
                         List<String> paramFiles)
                  throws IOException,
                         org.apache.pig.tools.parameters.ParseException

Throws:

IOException

org.apache.pig.tools.parameters.ParseException

substitute

public String substitute(String line)
                  throws ParameterSubstitutionException

Throws:

ParameterSubstitutionException

substitute

public String substitute(String line,
                         String parentKey)
                  throws ParameterSubstitutionException

Throws:

ParameterSubstitutionException