Uses of Class
org.apache.pig.backend.executionengine.ExecException

Packages that use ExecException

org.apache.hadoop.zebra.pig.comparator	Utilities to allow PIG Storer to generate keys for sorted Zebra tables
org.apache.pig	Public interfaces and classes for Pig.
org.apache.pig.backend.executionengine
org.apache.pig.backend.hadoop
org.apache.pig.backend.hadoop.executionengine
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
org.apache.pig.backend.hadoop.executionengine.physicalLayer	Implementation of physical operators that use hadoop as the execution engine and data storage.
org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators
org.apache.pig.backend.hadoop.executionengine.util
org.apache.pig.backend.hadoop.streaming
org.apache.pig.builtin	This package contains builtin Pig UDFs.
org.apache.pig.data	This package contains implementations of Pig specific data types as well as support functions for reading, writing, and using all Pig data types.
org.apache.pig.impl
org.apache.pig.impl.builtin
org.apache.pig.impl.streaming
org.apache.pig.pen
org.apache.pig.pen.util
org.apache.pig.piggybank.evaluation
org.apache.pig.piggybank.evaluation.datetime.truncate
org.apache.pig.scripting
org.apache.pig.scripting.jython
org.apache.pig.tools
org.apache.pig.tools.grunt

Uses of ExecException in org.apache.hadoop.zebra.pig.comparator

Methods in org.apache.hadoop.zebra.pig.comparator that throw ExecException

protected void	LeafExpr.append(org.apache.hadoop.zebra.pig.comparator.EncodingOutputStream out, Tuple tuple)
protected abstract void	LeafExpr.appendObject(org.apache.hadoop.zebra.pig.comparator.EncodingOutputStream out, Object object)
protected void	BagExpr.appendObject(org.apache.hadoop.zebra.pig.comparator.EncodingOutputStream out, Object object)
org.apache.hadoop.io.BytesWritable	KeyGenerator.generateKey(Tuple t) Generate the binary key for the input tuple

Uses of ExecException in org.apache.pig

Methods in org.apache.pig that throw ExecException

protected PigStats

PigServer.launchPlan(PhysicalPlan pp, String jobName) A common method for launching the jobs according to the physical plan

Constructors in org.apache.pig that throw ExecException

PigServer(ExecType execType)

PigServer(ExecType execType, Properties properties)

PigServer(PigContext context)

PigServer(PigContext context, boolean connect)

PigServer(String execTypeString)

Uses of ExecException in org.apache.pig.backend.executionengine

Methods in org.apache.pig.backend.executionengine that throw ExecException

String	ExecJob.getAlias() Returns the alias of relation generated by this job
void	ExecJob.getLogs(OutputStream log) Collecting various forms of outputs
Iterator<Tuple>	ExecJob.getResults() if query has executed successfully we want to retrieve the results via iterating over them.
void	ExecJob.getSTDError(OutputStream error)
void	ExecJob.getSTDOut(OutputStream out)
boolean	ExecJob.hasCompleted() true is the physical plan has executed successfully and results are ready to be retrieved
void	ExecJob.kill() Kills current job.

Uses of ExecException in org.apache.pig.backend.hadoop

Methods in org.apache.pig.backend.hadoop that throw ExecException

static byte	HDataType.findTypeFromNullableWritable(PigNullableWritable o)
static PigNullableWritable	HDataType.getWritableComparableTypes(byte type)
static PigNullableWritable	HDataType.getWritableComparableTypes(Object o, byte keyType)

Uses of ExecException in org.apache.pig.backend.hadoop.executionengine

Methods in org.apache.pig.backend.hadoop.executionengine that throw ExecException

String	HJob.getAlias()
void	HJob.getLogs(OutputStream log)
Iterator<Tuple>	HJob.getResults()
void	HJob.getSTDError(OutputStream error)
void	HJob.getSTDOut(OutputStream out)
boolean	HJob.hasCompleted()
void	HExecutionEngine.init()
void	HExecutionEngine.init(Properties properties)
void	HJob.kill()
void	HExecutionEngine.updateConfiguration(Properties newConfiguration)

Uses of ExecException in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer that throw ExecException

PigStats	MapReduceLauncher.launchPig(PhysicalPlan php, String grpName, PigContext pc)
abstract PigStats	Launcher.launchPig(PhysicalPlan php, String grpName, PigContext pc) Method to launch pig for hadoop either for a cluster's job tracker or for a local job runner.

Constructors in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer that throw ExecException

MergeJoinIndexer(String funcSpec, String innerPlan, String serializedPhyPlan, String udfCntxtSignature, String scope, String ignoreNulls)

Uses of ExecException in org.apache.pig.backend.hadoop.executionengine.physicalLayer

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer that throw ExecException

static Object	PhysicalOperator.getDummy(byte dataType)
Result	PhysicalOperator.getNext(Boolean b)
Result	PhysicalOperator.getNext(DataBag db)
Result	PhysicalOperator.getNext(DataByteArray ba)
Result	PhysicalOperator.getNext(Double d)
Result	PhysicalOperator.getNext(Float f)
Result	PhysicalOperator.getNext(Integer i)
Result	PhysicalOperator.getNext(Long l)
Result	PhysicalOperator.getNext(Map m)
Result	PhysicalOperator.getNext(Object obj, byte dataType) Implementations that call into the different versions of getNext are often identical, differing only in the signature of the getNext() call they make.
Result	PhysicalOperator.getNext(String s)
Result	PhysicalOperator.getNext(Tuple t)
Result	PhysicalOperator.processInput() A generic method for parsing input that either returns the attached input if it exists or fetches it from its predecessor.

Uses of ExecException in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators that throw ExecException

protected Result	ExpressionOperator.accumChild(List<ExpressionOperator> child, Boolean b) Drive all the UDFs in accumulative mode
protected Result	ExpressionOperator.accumChild(List<ExpressionOperator> child, DataBag db) Drive all the UDFs in accumulative mode
protected Result	ExpressionOperator.accumChild(List<ExpressionOperator> child, DataByteArray dba) Drive all the UDFs in accumulative mode
protected Result	ExpressionOperator.accumChild(List<ExpressionOperator> child, Double d) Drive all the UDFs in accumulative mode
protected Result	ExpressionOperator.accumChild(List<ExpressionOperator> child, Float f) Drive all the UDFs in accumulative mode
protected Result	ExpressionOperator.accumChild(List<ExpressionOperator> child, Integer v) Drive all the UDFs in accumulative mode
protected Result	ExpressionOperator.accumChild(List<ExpressionOperator> child, Long l) Drive all the UDFs in accumulative mode
protected Result	ExpressionOperator.accumChild(List<ExpressionOperator> child, Map map) Drive all the UDFs in accumulative mode
protected Result	ExpressionOperator.accumChild(List<ExpressionOperator> child, Object o, byte dataType) Drive all the UDFs in accumulative mode
protected Result	ExpressionOperator.accumChild(List<ExpressionOperator> child, String s) Drive all the UDFs in accumulative mode
protected Result	ExpressionOperator.accumChild(List<ExpressionOperator> child, Tuple t) Drive all the UDFs in accumulative mode
protected <T extends Number> T	Add.add(T a, T b, byte dataType)
protected Result	POProject.consumeInputBag(Result input)
protected <T extends Number> T	Divide.divide(T a, T b, byte dataType)
protected <T extends Number> boolean	Divide.equalsZero(T a, byte dataType)
Result	POBinCond.genericGetNext(Object obj, byte dataType)
protected Result	ConstantExpression.genericGetNext(Object obj, byte dataType)
protected <T extends Number> Result	Subtract.genericGetNext(T number, byte dataType)
protected <T extends Number> Result	Multiply.genericGetNext(T number, byte dataType)
protected <T extends Number> Result	Mod.genericGetNext(T number, byte dataType)
protected <T extends Number> Result	Divide.genericGetNext(T number, byte dataType)
protected <T extends Number> Result	Add.genericGetNext(T number, byte dataType)
int	POProject.getColumn()
String	POUserFunc.getFinal()
String	POUserFunc.getInitial()
String	POUserFunc.getIntermed()
Result	POProject.getNext() Fetches the input tuple and returns the requested column
Result	POUserFunc.getNext(Boolean b)
Result	POUserComparisonFunc.getNext(Boolean b)
Result	PORegexp.getNext(Boolean bool)
Result	POProject.getNext(Boolean b)
Result	POOr.getNext(Boolean b)
Result	PONot.getNext(Boolean b)
Result	POMapLookUp.getNext(Boolean b)
Result	POIsNull.getNext(Boolean b)
Result	POBinCond.getNext(Boolean b)
Result	POAnd.getNext(Boolean b)
Result	NotEqualToExpr.getNext(Boolean bool)
Result	LTOrEqualToExpr.getNext(Boolean bool)
Result	LessThanExpr.getNext(Boolean bool)
Result	GTOrEqualToExpr.getNext(Boolean bool)
Result	GreaterThanExpr.getNext(Boolean bool)
Result	EqualToExpr.getNext(Boolean bool)
Result	ConstantExpression.getNext(Boolean b)
Result	ComparisonOperator.getNext(Boolean b)
Result	POUserFunc.getNext(DataBag db)
Result	POUserComparisonFunc.getNext(DataBag db)
Result	PORelationToExprProject.getNext(DataBag db)
Result	POProject.getNext(DataBag db)
Result	POMapLookUp.getNext(DataBag db)
Result	POCast.getNext(DataBag bag)
Result	POBinCond.getNext(DataBag db)
Result	ExpressionOperator.getNext(DataBag db)
Result	ConstantExpression.getNext(DataBag db)
Result	ComparisonOperator.getNext(DataBag db)
Result	POUserFunc.getNext(DataByteArray ba)
Result	POUserComparisonFunc.getNext(DataByteArray ba)
Result	POProject.getNext(DataByteArray ba)
Result	POMapLookUp.getNext(DataByteArray ba)
Result	POCast.getNext(DataByteArray dba)
Result	POBinCond.getNext(DataByteArray ba)
Result	ConstantExpression.getNext(DataByteArray ba)
Result	ComparisonOperator.getNext(DataByteArray ba)
Result	Subtract.getNext(Double d)
Result	POUserFunc.getNext(Double d)
Result	POUserComparisonFunc.getNext(Double d)
Result	POProject.getNext(Double d)
Result	PONegative.getNext(Double d)
Result	POMapLookUp.getNext(Double d)
Result	POCast.getNext(Double d)
Result	POBinCond.getNext(Double d)
Result	Multiply.getNext(Double d)
Result	Divide.getNext(Double d)
Result	ConstantExpression.getNext(Double d)
Result	ComparisonOperator.getNext(Double d)
Result	Add.getNext(Double d)
Result	Subtract.getNext(Float f)
Result	POUserFunc.getNext(Float f)
Result	POUserComparisonFunc.getNext(Float f)
Result	POProject.getNext(Float f)
Result	PONegative.getNext(Float f)
Result	POMapLookUp.getNext(Float f)
Result	POCast.getNext(Float f)
Result	POBinCond.getNext(Float f)
Result	Multiply.getNext(Float f)
Result	Divide.getNext(Float f)
Result	ConstantExpression.getNext(Float f)
Result	ComparisonOperator.getNext(Float f)
Result	Add.getNext(Float f)
Result	Subtract.getNext(Integer i)
Result	POUserFunc.getNext(Integer i)
Result	POUserComparisonFunc.getNext(Integer i)
Result	POProject.getNext(Integer i)
Result	PONegative.getNext(Integer i)
Result	POMapLookUp.getNext(Integer i)
Result	POCast.getNext(Integer i)
Result	POBinCond.getNext(Integer i)
Result	Multiply.getNext(Integer i)
Result	Mod.getNext(Integer i)
Result	Divide.getNext(Integer i)
Result	ConstantExpression.getNext(Integer i)
Result	ComparisonOperator.getNext(Integer i)
Result	Add.getNext(Integer i)
Result	Subtract.getNext(Long l)
Result	POUserFunc.getNext(Long l)
Result	POUserComparisonFunc.getNext(Long l)
Result	POProject.getNext(Long l)
Result	PONegative.getNext(Long l)
Result	POMapLookUp.getNext(Long l)
Result	POCast.getNext(Long l)
Result	POBinCond.getNext(Long l)
Result	Multiply.getNext(Long l)
Result	Mod.getNext(Long i)
Result	Divide.getNext(Long l)
Result	ConstantExpression.getNext(Long l)
Result	ComparisonOperator.getNext(Long l)
Result	Add.getNext(Long l)
Result	POUserFunc.getNext(Map m)
Result	POUserComparisonFunc.getNext(Map m)
Result	POProject.getNext(Map m)
Result	POMapLookUp.getNext(Map m)
Result	POCast.getNext(Map m)
Result	POBinCond.getNext(Map m)
Result	ConstantExpression.getNext(Map m)
Result	ComparisonOperator.getNext(Map m)
Result	POUserFunc.getNext(String s)
Result	POUserComparisonFunc.getNext(String s)
Result	POProject.getNext(String s)
Result	POMapLookUp.getNext(String s)
Result	POCast.getNext(String str)
Result	POBinCond.getNext(String s)
Result	ConstantExpression.getNext(String s)
Result	ComparisonOperator.getNext(String s)
Result	POUserFunc.getNext(Tuple tIn)
Result	POUserComparisonFunc.getNext(Tuple in)
Result	POProject.getNext(Tuple t) Asked for Tuples.
Result	POMapLookUp.getNext(Tuple t)
Result	POCast.getNext(Tuple t)
Result	POBinCond.getNext(Tuple t)
Result	ConstantExpression.getNext(Tuple t)
Result	ComparisonOperator.getNext(Tuple t)
protected <T extends Number> T	Mod.mod(T a, T b, byte dataType)
protected <T extends Number> T	Multiply.multiply(T a, T b, byte dataType)
Result	POUserFunc.processInput()
Result	POMapLookUp.processInput()
protected Result	POProject.processInputBag()
void	POUserFunc.setAlgebraicFunction(byte Function)
protected <T extends Number> T	Subtract.subtract(T a, T b, byte dataType)

Uses of ExecException in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that throw ExecException

protected Tuple	POLocalRearrange.constructLROutput(List<Result> resLst, List<Result> secondaryResLst, Tuple value)
protected Tuple	POPreCombinerLocalRearrange.constructLROutput(List<Result> resLst, Tuple value)
protected Tuple	POCollectedGroup.constructOutput(List<Result> resLst, Tuple value)
protected DataBag	POPartitionRearrange.constructPROutput(List<Result> resLst, Tuple value)
protected Tuple	POForEach.createTuple(Object[] data)
protected Object	POLocalRearrange.getKeyFromResult(List<Result> resLst, byte type)
Result	POUnion.getNext(Tuple t) The code below, tries to follow our single threaded shared execution model with execution being passed around each non-drained input
Result	POStream.getNext(Tuple t)
Result	POStore.getNext(Tuple t)
Result	POSplit.getNext(Tuple t)
Result	POSortedDistinct.getNext(Tuple t)
Result	POSort.getNext(Tuple t)
Result	POPreCombinerLocalRearrange.getNext(Tuple t) Calls getNext on the generate operator inside the nested physical plan.
Result	POPartitionRearrange.getNext(Tuple t) Calls getNext on the generate operator inside the nested physical plan.
Result	POPackageLite.getNext(Tuple t) Similar to POPackage.getNext except that only one input is expected with index 0 and ReadOnceBag is used instead of DefaultDataBag.
Result	POPackage.getNext(Tuple t) From the inputs, constructs the output tuple for this co-group in the required format which is (key, {bag of tuples from input 1}, {bag of tuples from input 2}, ...)
Result	POOptimizedForEach.getNext(Tuple t) Calls getNext on the generate operator inside the nested physical plan and returns it maintaining an additional state to denote the begin and end of the nested plan processing.
Result	POMultiQueryPackage.getNext(Tuple t) Constructs the output tuple from the inputs.
Result	POMergeJoin.getNext(Tuple t)
Result	POMergeCogroup.getNext(Tuple t)
Result	POLocalRearrange.getNext(Tuple t) Calls getNext on the generate operator inside the nested physical plan.
Result	POLoad.getNext(Tuple t) The main method used by this operator's successor to read tuples from the specified file using the specified load function.
Result	POLimit.getNext(Tuple t) Counts the number of tuples processed into static variable soFar, if the number of tuples processed reach the limit, return EOP; Otherwise, return the tuple
Result	POJoinPackage.getNext(Tuple t) Calls getNext to get next ForEach result.
Result	POGlobalRearrange.getNext(Tuple t)
Result	POFRJoin.getNext(Tuple t)
Result	POForEach.getNext(Tuple t) Calls getNext on the generate operator inside the nested physical plan and returns it maintaining an additional state to denote the begin and end of the nested plan processing.
Result	POFilter.getNext(Tuple t) Attaches the proccesed input tuple to the expression plan and checks if comparison operator returns a true.
Result	PODistinct.getNext(Tuple t)
Result	PODemux.getNext(Tuple t)
Result	POCombinerPackage.getNext(Tuple t)
Result	POCollectedGroup.getNext(Tuple t)
Result	POStream.getNextHelper(Tuple t)
protected Tuple	POPackage.getValueTuple(NullableTuple ntup, int index)
Tuple	POPackageLite.getValueTuple(NullableTuple ntup, int index, Object key) Makes use of the superclass method, but this requires an additional parameter key passed by ReadOnceBag.
protected Result	POForEach.processPlan()
void	POLocalRearrange.setIndex(int index) Sets the co-group index of this operator
void	POLocalRearrange.setMultiQueryIndex(int index) Sets the multi-query index of this operator
void	POMergeJoin.throwProcessingException(boolean withCauseException, Exception e)

Constructors in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that throw ExecException

POFRJoin(OperatorKey k, int rp, List<PhysicalOperator> inp, List<List<PhysicalPlan>> ppLists, List<List<Byte>> keyTypes, FileSpec[] replFiles, int fragment, boolean isLeftOuter, Tuple nullTuple)

Uses of ExecException in org.apache.pig.backend.hadoop.executionengine.util

Methods in org.apache.pig.backend.hadoop.executionengine.util that throw ExecException

static FileSpec

MapRedUtil.checkLeafIsStore(PhysicalPlan plan, PigContext pigContext)

Uses of ExecException in org.apache.pig.backend.hadoop.streaming

Methods in org.apache.pig.backend.hadoop.streaming that throw ExecException

void	HadoopExecutableManager.configure(POStream stream)

Uses of ExecException in org.apache.pig.builtin

Methods in org.apache.pig.builtin that throw ExecException

protected static Tuple	LongAvg.combine(DataBag values)
protected static Tuple	IntAvg.combine(DataBag values)
protected static Tuple	FloatAvg.combine(DataBag values)
protected static Tuple	DoubleAvg.combine(DataBag values)
protected static Tuple	AVG.combine(DataBag values)
protected static long	LongAvg.count(Tuple input)
protected static long	IntAvg.count(Tuple input)
protected static long	FloatAvg.count(Tuple input)
protected static long	DoubleAvg.count(Tuple input)
protected static long	AVG.count(Tuple input)
protected static String	StringMax.max(Tuple input)
protected static Double	MAX.max(Tuple input)
protected static Long	LongMax.max(Tuple input)
protected static Integer	IntMax.max(Tuple input)
protected static Float	FloatMax.max(Tuple input)
protected static Double	DoubleMax.max(Tuple input)
protected static Double	MAX.maxDoubles(Tuple input)
protected static String	StringMin.min(Tuple input)
protected static Double	MIN.min(Tuple input)
protected static Long	LongMin.min(Tuple input)
protected static Integer	IntMin.min(Tuple input)
protected static Float	FloatMin.min(Tuple input)
protected static Double	DoubleMin.min(Tuple input)
protected static Double	MIN.minDoubles(Tuple input)
protected static Double	SUM.sum(Tuple input)
protected static Long	LongSum.sum(Tuple input)
protected static Long	LongAvg.sum(Tuple input)
protected static Long	IntSum.sum(Tuple input)
protected static Long	IntAvg.sum(Tuple input)
protected static Double	FloatSum.sum(Tuple input)
protected static Double	FloatAvg.sum(Tuple input)
protected static Double	DoubleSum.sum(Tuple input)
protected static Double	DoubleAvg.sum(Tuple input)
protected static Long	COUNT_STAR.sum(Tuple input)
protected static Long	COUNT.sum(Tuple input)
protected static Double	AVG.sum(Tuple input)
protected static Double	SUM.sumDoubles(Tuple input)
protected static Double	FloatSum.sumDoubles(Tuple input)
protected static Long	IntSum.sumLongs(Tuple input)

Uses of ExecException in org.apache.pig.data

Methods in org.apache.pig.data that throw ExecException

static Schema.FieldSchema	DataType.determineFieldSchema(Object o) Determine the field schema of an object
static Schema.FieldSchema	DataType.determineFieldSchema(ResourceSchema.ResourceFieldSchema rcFieldSchema) Determine the field schema of an ResourceFieldSchema
Object	Tuple.get(int fieldNum) Get the value in a given field.
Object	TargetedTuple.get(int fieldNum)
Object	DefaultTuple.get(int fieldNum) Get the value in a given field.
byte	Tuple.getType(int fieldNum) Find the type of a given field.
byte	TargetedTuple.getType(int fieldNum)
byte	DefaultTuple.getType(int fieldNum) Find the type of a given field.
boolean	Tuple.isNull(int fieldNum) Find out if a given field is null.
boolean	TargetedTuple.isNull(int fieldNum)
boolean	DefaultTuple.isNull(int fieldNum) Find out if a given field is null.
Object	InterSedes.readDatum(DataInput in) Get the next object from DataInput in
static Object	DataReaderWriter.readDatum(DataInput in)
Object	BinInterSedes.readDatum(DataInput in)
Object	InterSedes.readDatum(DataInput in, byte type) Get the next object from DataInput in of the type of type argument The type information has been read from DataInput.
static Object	DataReaderWriter.readDatum(DataInput in, byte type)
Object	BinInterSedes.readDatum(DataInput in, byte type)
void	Tuple.set(int fieldNum, Object val) Set the value in a given field.
void	TargetedTuple.set(int fieldNum, Object val)
void	DefaultTuple.set(int fieldNum, Object val) Set the value in a given field.
static DataBag	DataType.toBag(Object o) If this object is a bag, return it as a bag.
static byte[]	DataType.toBytes(Object o)
static byte[]	DataType.toBytes(Object o, byte type)
String	Tuple.toDelimitedString(String delim) Write a tuple of atomic values into a string.
String	TargetedTuple.toDelimitedString(String delim)
String	DefaultTuple.toDelimitedString(String delim) Write a tuple of atomic values into a string.
static Double	DataType.toDouble(Object o) Force a data object to a Double, if possible.
static Double	DataType.toDouble(Object o, byte type) Force a data object to a Double, if possible.
static Float	DataType.toFloat(Object o) Force a data object to a Float, if possible.
static Float	DataType.toFloat(Object o, byte type) Force a data object to a Float, if possible.
static Integer	DataType.toInteger(Object o) Force a data object to an Integer, if possible.
static Integer	DataType.toInteger(Object o, byte type) Force a data object to an Integer, if possible.
static Long	DataType.toLong(Object o) Force a data object to a Long, if possible.
static Long	DataType.toLong(Object o, byte type) Force a data object to a Long, if possible.
static Map<String,Object>	DataType.toMap(Object o) If this object is a map, return it as a map.
static String	DataType.toString(Object o) Force a data object to a String, if possible.
static String	DataType.toString(Object o, byte type) Force a data object to a String, if possible.
static Tuple	DataType.toTuple(Object o) If this object is a tuple, return it as a tuple.

Uses of ExecException in org.apache.pig.impl

Methods in org.apache.pig.impl that throw ExecException

void	PigContext.connect()
ExecutableManager	PigContext.createExecutableManager() Create a new ExecutableManager depending on the ExecType.

Uses of ExecException in org.apache.pig.impl.builtin

Methods in org.apache.pig.impl.builtin that throw ExecException

void	SampleLoader.computeSamples(ArrayList<Pair<FileSpec,Boolean>> inputs, PigContext pc)
void	PoissonSampleLoader.computeSamples(ArrayList<Pair<FileSpec,Boolean>> inputs, PigContext pc) Computes the number of samples for the loader
Object	IdentityColumn.exec(Tuple input)

Uses of ExecException in org.apache.pig.impl.streaming

Methods in org.apache.pig.impl.streaming that throw ExecException

void	ExecutableManager.configure(POStream stream) Configure and initialize the ExecutableManager.
static InputHandler	HandlerFactory.createInputHandler(StreamingCommand command) Create an InputHandler for the given input specification of the StreamingCommand.
static OutputHandler	HandlerFactory.createOutputHandler(StreamingCommand command) Create an OutputHandler for the given output specification of the StreamingCommand.

Constructors in org.apache.pig.impl.streaming that throw ExecException

FileInputHandler(StreamingCommand.HandleSpec handleSpec)

FileOutputHandler(StreamingCommand.HandleSpec handleSpec)

Uses of ExecException in org.apache.pig.pen

Methods in org.apache.pig.pen that throw ExecException

Map<LOLoad,DataBag>

AugmentBaseDataVisitor.getNewBaseData()

Uses of ExecException in org.apache.pig.pen.util

Methods in org.apache.pig.pen.util that throw ExecException

Object	ExampleTuple.get(int fieldNum)
byte	ExampleTuple.getType(int fieldNum)
boolean	ExampleTuple.isNull(int fieldNum)
void	ExampleTuple.set(int fieldNum, Object val)
String	ExampleTuple.toDelimitedString(String delim)

Uses of ExecException in org.apache.pig.piggybank.evaluation

Methods in org.apache.pig.piggybank.evaluation that throw ExecException

protected static Tuple	ExtremalTupleByNthField.extreme(int pind, int psign, Tuple input, PigProgressable reporter)
protected static Tuple	MaxTupleBy1stField.max(Tuple input, PigProgressable reporter)
protected static int	ExtremalTupleByNthField.parseFieldIndex(String inputFieldIndex)

Constructors in org.apache.pig.piggybank.evaluation that throw ExecException

ExtremalTupleByNthField.HelperClass()

ExtremalTupleByNthField.HelperClass(String fieldIndexString)

ExtremalTupleByNthField.HelperClass(String fieldIndexString, String order)

ExtremalTupleByNthField()
Constructors

ExtremalTupleByNthField(String fieldIndexString)

ExtremalTupleByNthField(String fieldIndexString, String order)

Uses of ExecException in org.apache.pig.piggybank.evaluation.datetime.truncate

Methods in org.apache.pig.piggybank.evaluation.datetime.truncate that throw ExecException

static org.joda.time.DateTime

ISOHelper.parseDateTime(Tuple input)

Uses of ExecException in org.apache.pig.scripting

Methods in org.apache.pig.scripting that throw ExecException

Map<String,List<PigStats>>

ScriptEngine.run(PigContext pigContext, String scriptFile) Runs a script file.

Uses of ExecException in org.apache.pig.scripting.jython

Methods in org.apache.pig.scripting.jython that throw ExecException

static Object

JythonUtils.pythonToPig(org.python.core.PyObject pyObject)

Uses of ExecException in org.apache.pig.tools

Methods in org.apache.pig.tools that throw ExecException

List<ExecJob>

ToolsPigServer.runPlan(LogicalPlan newPlan, String jobName) Given a (modified) new logical plan, run the script.

Constructors in org.apache.pig.tools that throw ExecException

ToolsPigServer(ExecType execType, Properties properties)

ToolsPigServer(PigContext ctx)

ToolsPigServer(String execTypeString)

Uses of ExecException in org.apache.pig.tools.grunt

Constructors in org.apache.pig.tools.grunt that throw ExecException

Grunt(BufferedReader in, PigContext pigContext)