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

Packages that use ExecException

Package	Description
org.apache.pig	Public interfaces and classes for Pig.
org.apache.pig.backend.executionengine
org.apache.pig.backend.hadoop
org.apache.pig.backend.hadoop.accumulo
org.apache.pig.backend.hadoop.executionengine
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners
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.spark
org.apache.pig.backend.hadoop.executionengine.spark.operator
org.apache.pig.backend.hadoop.executionengine.tez
org.apache.pig.backend.hadoop.executionengine.tez.plan.operator
org.apache.pig.backend.hadoop.executionengine.tez.plan.udf
org.apache.pig.backend.hadoop.executionengine.tez.runtime
org.apache.pig.backend.hadoop.executionengine.tez.util
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.impl.util.avro
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.groovy
org.apache.pig.scripting.jruby
org.apache.pig.scripting.jython
org.apache.pig.tools
org.apache.pig.tools.grunt

Uses of ExecException in org.apache.pig

Methods in org.apache.pig that throw ExecException

Modifier and Type	Method and Description
protected PigStats	PigServer.launchPlan(LogicalPlan lp, String jobName) A common method for launching the jobs according to the logical plan

Constructors in org.apache.pig that throw ExecException

Constructor and Description
PigServer(ExecType execType)
PigServer(ExecType execType, org.apache.hadoop.conf.Configuration conf)
PigServer(ExecType execType, Properties properties)
PigServer(PigContext context)
PigServer(PigContext context, boolean connect)
PigServer(Properties properties)
PigServer(String execTypeString)
PigServer(String execTypeString, Properties properties)

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

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

Modifier and Type	Method and Description
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	ExecutionEngine.init() This method is responsible for the initialization of the ExecutionEngine.
void	ExecJob.kill() Kills current job.
PigStats	ExecutionEngine.launchPig(LogicalPlan lp, String grpName, PigContext pc) This method is responsible for the actual execution of a LogicalPlan.
void	ExecutionEngine.setConfiguration(Properties newConfiguration) Responsible for updating the properties for the ExecutionEngine.

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

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

Modifier and Type	Method and Description
static byte	HDataType.findTypeFromClassName(String className)
static byte	HDataType.findTypeFromNullableWritable(PigNullableWritable o)
static PigNullableWritable	HDataType.getNewWritableComparable(byte keyType)
static PigNullableWritable	HDataType.getWritableComparable(String className)
static PigNullableWritable	HDataType.getWritableComparableTypes(byte type)
static PigNullableWritable	HDataType.getWritableComparableTypes(Object o, byte keyType)

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

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

Modifier and Type	Method and Description
protected Collection<org.apache.accumulo.core.data.Mutation>	AccumuloStorage.getMutations(Tuple tuple)
protected abstract Collection<org.apache.accumulo.core.data.Mutation>	AbstractAccumuloStorage.getMutations(Tuple tuple)
void	AbstractAccumuloStorage.putNext(Tuple tuple)

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

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

Modifier and Type	Method and Description
String	HJob.getAlias()
org.apache.hadoop.mapred.JobConf	HExecutionEngine.getExecConf(Properties properties)
void	HJob.getLogs(OutputStream log)
Iterator<Tuple>	HJob.getResults()
org.apache.hadoop.mapred.JobConf	HExecutionEngine.getS3Conf()
void	HJob.getSTDError(OutputStream error)
void	HJob.getSTDOut(OutputStream out)
boolean	HJob.hasCompleted()
void	HExecutionEngine.init()
void	HJob.kill()
PigStats	HExecutionEngine.launchPig(LogicalPlan lp, String grpName, PigContext pc)
void	HExecutionEngine.setConfiguration(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

Modifier and Type	Method and Description
PigStats	MapReduceLauncher.launchPig(PhysicalPlan php, String grpName, PigContext pc)

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

Constructor and Description
MergeJoinIndexer(String funcSpec, String innerPlan, String serializedPhyPlan, String udfCntxtSignature, String scope, String ignoreNulls)

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

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

Modifier and Type	Method and Description
protected float[]	WeightedRangePartitioner.getProbVec(Tuple values)

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

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

Modifier and Type	Method and Description
Result	PhysicalOperator.getNext(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.getNextBigDecimal()
Result	PhysicalOperator.getNextBigInteger()
Result	PhysicalOperator.getNextBoolean()
Result	PhysicalOperator.getNextDataBag()
Result	PhysicalOperator.getNextDataByteArray()
Result	PhysicalOperator.getNextDateTime()
Result	PhysicalOperator.getNextDouble()
Result	PhysicalOperator.getNextFloat()
Result	PhysicalOperator.getNextInteger()
Result	PhysicalOperator.getNextLong()
Result	PhysicalOperator.getNextMap()
Result	PhysicalOperator.getNextString()
Result	PhysicalOperator.getNextTuple()
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

Modifier and Type	Method and Description
protected Result	ExpressionOperator.accumChild(List<ExpressionOperator> child, byte dataType) Drive all the UDFs in accumulative mode
protected Number	Add.add(Number a, Number b, byte dataType)
protected Result	POProject.consumeInputBag(Result input)
protected Number	Divide.divide(Number a, Number b, byte dataType)
protected boolean	Divide.equalsZero(Number a, byte dataType)
protected Result	Subtract.genericGetNext(byte dataType)
Result	POBinCond.genericGetNext(byte dataType)
protected Result	Multiply.genericGetNext(byte dataType)
protected Result	Mod.genericGetNext(byte dataType)
protected Result	Divide.genericGetNext(byte dataType)
protected Result	Add.genericGetNext(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	Subtract.getNextBigDecimal()
Result	POUserFunc.getNextBigDecimal()
Result	POUserComparisonFunc.getNextBigDecimal()
Result	POProject.getNextBigDecimal()
Result	PONegative.getNextBigDecimal()
Result	POCast.getNextBigDecimal()
Result	POBinCond.getNextBigDecimal()
Result	Multiply.getNextBigDecimal()
Result	Divide.getNextBigDecimal()
Result	ConstantExpression.getNextBigDecimal()
Result	Add.getNextBigDecimal()
Result	Subtract.getNextBigInteger()
Result	POUserFunc.getNextBigInteger()
Result	POUserComparisonFunc.getNextBigInteger()
Result	POProject.getNextBigInteger()
Result	PONegative.getNextBigInteger()
Result	POCast.getNextBigInteger()
Result	POBinCond.getNextBigInteger()
Result	Multiply.getNextBigInteger()
Result	Mod.getNextBigInteger()
Result	Divide.getNextBigInteger()
Result	ConstantExpression.getNextBigInteger()
Result	Add.getNextBigInteger()
Result	POUserFunc.getNextBoolean()
Result	POUserComparisonFunc.getNextBoolean()
Result	PORegexp.getNextBoolean()
Result	POProject.getNextBoolean()
Result	POOr.getNextBoolean()
Result	PONot.getNextBoolean()
Result	POMapLookUp.getNextBoolean()
Result	POIsNull.getNextBoolean()
Result	POCast.getNextBoolean()
Result	POBinCond.getNextBoolean()
Result	POAnd.getNextBoolean()
Result	NotEqualToExpr.getNextBoolean()
Result	LessThanExpr.getNextBoolean()
Result	LTOrEqualToExpr.getNextBoolean()
Result	GreaterThanExpr.getNextBoolean()
Result	GTOrEqualToExpr.getNextBoolean()
Result	EqualToExpr.getNextBoolean()
Result	ConstantExpression.getNextBoolean()
Result	ComparisonOperator.getNextBoolean()
Result	POUserFunc.getNextDataBag()
Result	POUserComparisonFunc.getNextDataBag()
Result	PORelationToExprProject.getNextDataBag()
Result	POProject.getNextDataBag()
Result	POMapLookUp.getNextDataBag()
Result	POCast.getNextDataBag()
Result	POBinCond.getNextDataBag()
Result	ExpressionOperator.getNextDataBag()
Result	ConstantExpression.getNextDataBag()
Result	ComparisonOperator.getNextDataBag()
Result	POUserFunc.getNextDataByteArray()
Result	POUserComparisonFunc.getNextDataByteArray()
Result	POProject.getNextDataByteArray()
Result	POMapLookUp.getNextDataByteArray()
Result	POCast.getNextDataByteArray()
Result	POBinCond.getNextDataByteArray()
Result	ConstantExpression.getNextDataByteArray()
Result	ComparisonOperator.getNextDataByteArray()
Result	POUserFunc.getNextDateTime()
Result	POUserComparisonFunc.getNextDateTime()
Result	POProject.getNextDateTime()
Result	POMapLookUp.getNextDateTime()
Result	POCast.getNextDateTime()
Result	POBinCond.getNextDateTime()
Result	ConstantExpression.getNextDateTime()
Result	ComparisonOperator.getNextDateTime()
Result	Subtract.getNextDouble()
Result	POUserFunc.getNextDouble()
Result	POUserComparisonFunc.getNextDouble()
Result	POProject.getNextDouble()
Result	PONegative.getNextDouble()
Result	POMapLookUp.getNextDouble()
Result	POCast.getNextDouble()
Result	POBinCond.getNextDouble()
Result	Multiply.getNextDouble()
Result	Divide.getNextDouble()
Result	ConstantExpression.getNextDouble()
Result	ComparisonOperator.getNextDouble()
Result	Add.getNextDouble()
Result	Subtract.getNextFloat()
Result	POUserFunc.getNextFloat()
Result	POUserComparisonFunc.getNextFloat()
Result	POProject.getNextFloat()
Result	PONegative.getNextFloat()
Result	POMapLookUp.getNextFloat()
Result	POCast.getNextFloat()
Result	POBinCond.getNextFloat()
Result	Multiply.getNextFloat()
Result	Divide.getNextFloat()
Result	ConstantExpression.getNextFloat()
Result	ComparisonOperator.getNextFloat()
Result	Add.getNextFloat()
Result	Subtract.getNextInteger()
Result	POUserFunc.getNextInteger()
Result	POUserComparisonFunc.getNextInteger()
Result	POProject.getNextInteger()
Result	PONegative.getNextInteger()
Result	POMapLookUp.getNextInteger()
Result	POCast.getNextInteger()
Result	POBinCond.getNextInteger()
Result	Multiply.getNextInteger()
Result	Mod.getNextInteger()
Result	Divide.getNextInteger()
Result	ConstantExpression.getNextInteger()
Result	ComparisonOperator.getNextInteger()
Result	Add.getNextInteger()
Result	Subtract.getNextLong()
Result	POUserFunc.getNextLong()
Result	POUserComparisonFunc.getNextLong()
Result	POProject.getNextLong()
Result	PONegative.getNextLong()
Result	POMapLookUp.getNextLong()
Result	POCast.getNextLong()
Result	POBinCond.getNextLong()
Result	Multiply.getNextLong()
Result	Mod.getNextLong()
Result	Divide.getNextLong()
Result	ConstantExpression.getNextLong()
Result	ComparisonOperator.getNextLong()
Result	Add.getNextLong()
Result	POUserFunc.getNextMap()
Result	POUserComparisonFunc.getNextMap()
Result	POProject.getNextMap()
Result	POMapLookUp.getNextMap()
Result	POCast.getNextMap()
Result	POBinCond.getNextMap()
Result	ConstantExpression.getNextMap()
Result	ComparisonOperator.getNextMap()
Result	POUserFunc.getNextString()
Result	POUserComparisonFunc.getNextString()
Result	POProject.getNextString()
Result	POMapLookUp.getNextString()
Result	POCast.getNextString()
Result	POBinCond.getNextString()
Result	ConstantExpression.getNextString()
Result	ComparisonOperator.getNextString()
Result	POUserFunc.getNextTuple()
Result	POUserComparisonFunc.getNextTuple()
Result	POProject.getNextTuple() Asked for Tuples.
Result	POMapLookUp.getNextTuple()
Result	POCast.getNextTuple()
Result	POBinCond.getNextTuple()
Result	ConstantExpression.getNextTuple()
Result	ComparisonOperator.getNextTuple()
Type	POUserFunc.getOriginalReturnType()
protected Number	Mod.mod(Number a, Number b, byte dataType)
protected Number	Multiply.multiply(Number a, Number b, byte dataType)
Result	POUserFunc.processInput()
Result	POMapLookUp.processInput()
protected Result	POProject.processInputBag()
void	POUserFunc.setAlgebraicFunction(byte Function)
protected Number	Subtract.subtract(Number a, Number 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

Modifier and Type	Method and Description
protected Result	POCounter.addCounterValue(Result input) Add current task id and local counter value.
Result	PORank.addRank(Result input) Reads the output tuple from POCounter and the cumulative sum previously calculated.
void	Packager.attachInput(Object key, DataBag[] bags, boolean[] readOnce)
void	LitePackager.attachInput(Object key, DataBag[] bags, boolean[] readOnce)
void	JoinPackager.attachInput(Object key, DataBag[] bags, boolean[] readOnce)
void	CombinerPackager.attachInput(Object key, DataBag[] bags, boolean[] readOnce)
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 Result	POPoissonSample.createNumRowTuple(Tuple sample)
protected Tuple	POForEach.createTuple(Object[] data)
Object	Packager.getKey(PigNullableWritable key)
protected Object	POLocalRearrange.getKeyFromResult(List<Result> resLst, byte type)
Result	Packager.getNext()
Result	MultiQueryPackager.getNext() Constructs the output tuple from the inputs.
Result	LitePackager.getNext() Similar to POPackage.getNext except that only one input is expected with index 0 and ReadOnceBag is used instead of DefaultDataBag.
Result	JoinPackager.getNext() Calls getNext to get next ForEach result.
Result	CombinerPackager.getNext()
Result	POStream.getNextHelper(Tuple t)
Result	POUnion.getNextTuple() The code below, tries to follow our single threaded shared execution model with execution being passed around each non-drained input
Result	POStream.getNextTuple()
Result	POStore.getNextTuple()
Result	POSplit.getNextTuple()
Result	POSortedDistinct.getNextTuple()
Result	POSort.getNextTuple()
Result	POReservoirSample.getNextTuple()
Result	PORank.getNextTuple()
Result	POPreCombinerLocalRearrange.getNextTuple() Calls getNext on the generate operator inside the nested physical plan.
Result	POPoissonSample.getNextTuple()
Result	POPartitionRearrange.getNextTuple() Calls getNext on the generate operator inside the nested physical plan.
Result	POPartialAgg.getNextTuple()
Result	POPackage.getNextTuple() 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.getNextTuple() 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	POMergeJoin.getNextTuple()
Result	POMergeCogroup.getNextTuple()
Result	POLocalRearrange.getNextTuple() Calls getNext on the generate operator inside the nested physical plan.
Result	POLoad.getNextTuple() The main method used by this operator's successor to read tuples from the specified file using the specified load function.
Result	POLimit.getNextTuple() 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	POForEach.getNextTuple() 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.getNextTuple() Attaches the proccesed input tuple to the expression plan and checks if comparison operator returns a true.
Result	POFRJoin.getNextTuple()
Result	PODistinct.getNextTuple()
Result	PODemux.getNextTuple()
Result	POCross.getNextTuple()
Result	POCounter.getNextTuple()
Result	POCollectedGroup.getNextTuple()
Tuple	Packager.getValueTuple(PigNullableWritable keyWritable, NullableTuple ntup, int index)
Tuple	MultiQueryPackager.getValueTuple(PigNullableWritable keyWritable, NullableTuple ntup, int origIndex)
Tuple	LitePackager.getValueTuple(PigNullableWritable keyWritable, NullableTuple ntup, int index) Makes use of the superclass method, but this requires an additional parameter key passed by ReadOnceBag.
Tuple	CombinerPackager.getValueTuple(PigNullableWritable keyWritable, NullableTuple ntup, int index)
protected Tuple	POFRJoin.getValueTuple(POLocalRearrange lr, Tuple tuple)
protected boolean	POFRJoin.isKeyNull(Object key)
boolean	POForEach.needEndOfAllInputProcessing()
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
protected void	POFRJoinSpark.setUpHashMap()
protected void	POFRJoin.setUpHashMap() Builds the HashMaps by reading each replicated input from the DFS using a Load operator
void	POMergeJoin.throwProcessingException(boolean withCauseException, Exception e)

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

Constructor and Description
POBroadcastSpark(POBroadcastSpark copy)
POFRJoin(OperatorKey k, int rp, List<PhysicalOperator> inp, List<List<PhysicalPlan>> ppLists, List<List<Byte>> keyTypes, FileSpec[] replFiles, int fragment, boolean isLeftOuter, Tuple nullTuple)
POFRJoin(OperatorKey k, int rp, List<PhysicalOperator> inp, List<List<PhysicalPlan>> ppLists, List<List<Byte>> keyTypes, FileSpec[] replFiles, int fragment, boolean isLeftOuter, Tuple nullTuple, Schema[] inputSchemas, Schema[] keySchemas)
POFRJoin(POFRJoin copy)
POFRJoinSpark(POFRJoin copy)
POGlobalRearrange(POGlobalRearrange copy)

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

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

Modifier and Type	Method and Description
static void	SparkUtil.createIndexerSparkNode(SparkOperator baseSparkOp, String scope, NodeIdGenerator nig)

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

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

Modifier and Type	Method and Description
Result	POPoissonSampleSpark.getNextTuple()

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

Constructor and Description
POGlobalRearrangeSpark(POGlobalRearrange copy)

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

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

Modifier and Type	Method and Description
org.apache.hadoop.mapred.JobConf	TezExecutionEngine.getExecConf(Properties properties)

Uses of ExecException in org.apache.pig.backend.hadoop.executionengine.tez.plan.operator

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

Modifier and Type	Method and Description
void	BloomPackager.attachInput(Object key, DataBag[] bags, boolean[] readOnce)
void	POValueInputTez.attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf)
void	POSimpleTezLoad.attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf)
void	POShuffledValueInputTez.attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf)
void	POShuffleTezLoad.attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf)
void	PORankTez.attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf)
void	POIdentityInOutTez.attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf)
void	POFRJoinTez.attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf)
void	POCounterStatsTez.attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf)
void	POBloomFilterRearrangeTez.attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf)
void	POValueOutputTez.attachOutputs(Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs, org.apache.hadoop.conf.Configuration conf)
void	POStoreTez.attachOutputs(Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs, org.apache.hadoop.conf.Configuration conf)
void	POLocalRearrangeTez.attachOutputs(Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs, org.apache.hadoop.conf.Configuration conf)
void	POIdentityInOutTez.attachOutputs(Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs, org.apache.hadoop.conf.Configuration conf)
void	POCounterTez.attachOutputs(Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs, org.apache.hadoop.conf.Configuration conf)
void	POCounterStatsTez.attachOutputs(Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs, org.apache.hadoop.conf.Configuration conf)
void	POBuildBloomRearrangeTez.attachOutputs(Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs, org.apache.hadoop.conf.Configuration conf)
protected DataBag	POPartitionRearrangeTez.constructPROutput(List<Result> resLst, Tuple value)
Result	BloomPackager.getNext()
Result	POValueOutputTez.getNextTuple()
Result	POValueInputTez.getNextTuple()
Result	POStoreTez.getNextTuple()
Result	POSimpleTezLoad.getNextTuple() Previously, we reused the same Result object for all results, but we found certain operators (e.g.
Result	POShuffledValueInputTez.getNextTuple()
Result	POShuffleTezLoad.getNextTuple()
Result	PORankTez.getNextTuple()
Result	POPartitionRearrangeTez.getNextTuple() Calls getNext on the generate operator inside the nested physical plan.
Result	POLocalRearrangeTez.getNextTuple()
Result	POIdentityInOutTez.getNextTuple()
Result	POCounterTez.getNextTuple()
Result	POCounterStatsTez.getNextTuple()
Result	POBuildBloomRearrangeTez.getNextTuple()
Result	POBloomFilterRearrangeTez.getNextTuple()
protected Result	POLocalRearrangeTez.getRearrangedTuple()
void	POValueOutputTez.initialize(org.apache.tez.runtime.api.ProcessorContext processorContext)
void	POStoreTez.initialize(org.apache.tez.runtime.api.ProcessorContext processorContext)
void	POSimpleTezLoad.initialize(org.apache.tez.runtime.api.ProcessorContext processorContext)
void	POCounterTez.initialize(org.apache.tez.runtime.api.ProcessorContext processorContext)
protected void	POFRJoinTez.setUpHashMap() Builds the HashMaps by reading replicated inputs from broadcast edges

Constructors in org.apache.pig.backend.hadoop.executionengine.tez.plan.operator that throw ExecException

Constructor and Description
POFRJoinTez(POFRJoin copy, List<String> inputKeys)

Uses of ExecException in org.apache.pig.backend.hadoop.executionengine.tez.plan.udf

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

Modifier and Type	Method and Description
void	ReadScalarsTez.attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf)

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

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

Modifier and Type	Method and Description
void	TezInput.attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf) Attach the inputs to the operator.
void	TezOutput.attachOutputs(Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs, org.apache.hadoop.conf.Configuration conf)
void	TezTaskConfigurable.initialize(org.apache.tez.runtime.api.ProcessorContext processorContext)

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

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

Modifier and Type	Method and Description
static boolean	TezCompilerUtil.bagDataTypeInCombinePlan(PhysicalPlan combinePlan)

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

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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
void	HadoopExecutableManager.configure(POStream stream)

Uses of ExecException in org.apache.pig.builtin

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

Modifier and Type	Method and Description
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	BigIntegerAvg.combine(DataBag values)
protected static Tuple	BigDecimalAvg.combine(DataBag values)
protected static Tuple	AVG.combine(DataBag values)
static void	CubeDimensions.convertNullToUnknown(Tuple tuple)
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 BigInteger	BigIntegerAvg.count(Tuple input)
protected static BigDecimal	BigDecimalAvg.count(Tuple input)
protected static long	AVG.count(Tuple input)
protected static Long	AlgebraicLongMathBase.doTupleWork(Tuple input, AlgebraicMathBase.KnownOpProvider opProvider)
protected static Integer	AlgebraicIntMathBase.doTupleWork(Tuple input, AlgebraicMathBase.KnownOpProvider opProvider)
protected static Float	AlgebraicFloatMathBase.doTupleWork(Tuple input, AlgebraicMathBase.KnownOpProvider opProvider)
protected static Double	AlgebraicDoubleMathBase.doTupleWork(Tuple input, AlgebraicMathBase.KnownOpProvider opProvider)
protected static BigInteger	AlgebraicBigIntegerMathBase.doTupleWork(Tuple input, AlgebraicMathBase.KnownOpProvider opProvider)
protected static BigDecimal	AlgebraicBigDecimalMathBase.doTupleWork(Tuple input, AlgebraicMathBase.KnownOpProvider opProvider)
protected static Double	AlgebraicByteArrayMathBase.doTupleWork(Tuple input, AlgebraicMathBase.KnownOpProvider opProvider, byte expectedType)
protected static String	StringMax.max(Tuple input)
protected static org.joda.time.DateTime	DateTimeMax.max(Tuple input)
protected static String	StringMin.min(Tuple input)
protected static org.joda.time.DateTime	DateTimeMin.min(Tuple input)
protected static Long	LongAvg.sum(Tuple input)
protected static Long	IntAvg.sum(Tuple input)
protected static Double	FloatAvg.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 BigInteger	BigIntegerAvg.sum(Tuple input)
protected static BigDecimal	BigDecimalAvg.sum(Tuple input)
protected static Double	AVG.sum(Tuple input)

Uses of ExecException in org.apache.pig.data

Subclasses of ExecException in org.apache.pig.data

Modifier and Type	Class and Description
class	FieldIsNullException

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

Modifier and Type	Method and Description
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
protected abstract BigDecimal	SchemaTuple.generatedCodeGetBigDecimal(int fieldNum)
protected abstract BigInteger	SchemaTuple.generatedCodeGetBigInteger(int fieldNum)
protected abstract boolean	SchemaTuple.generatedCodeGetBoolean(int fieldNum)
protected abstract byte[]	SchemaTuple.generatedCodeGetBytes(int fieldNum)
protected abstract DataBag	SchemaTuple.generatedCodeGetDataBag(int fieldNum)
protected abstract org.joda.time.DateTime	SchemaTuple.generatedCodeGetDateTime(int fieldNum)
protected abstract double	SchemaTuple.generatedCodeGetDouble(int fieldNum)
abstract Object	SchemaTuple.generatedCodeGetField(int fieldNum)
protected abstract float	SchemaTuple.generatedCodeGetFloat(int fieldNum)
protected abstract int	SchemaTuple.generatedCodeGetInt(int fieldNum)
protected abstract long	SchemaTuple.generatedCodeGetLong(int fieldNum)
protected abstract Map<String,Object>	SchemaTuple.generatedCodeGetMap(int fieldNum)
protected abstract String	SchemaTuple.generatedCodeGetString(int fieldNum)
protected abstract Tuple	SchemaTuple.generatedCodeGetTuple(int fieldNum)
protected abstract SchemaTuple<T>	SchemaTuple.generatedCodeSet(SchemaTuple<?> t, boolean checkType)
protected abstract void	SchemaTuple.generatedCodeSetBigDecimal(int fieldNum, BigDecimal val)
protected abstract void	SchemaTuple.generatedCodeSetBigInteger(int fieldNum, BigInteger val)
protected abstract void	SchemaTuple.generatedCodeSetBoolean(int fieldNum, boolean val)
protected abstract void	SchemaTuple.generatedCodeSetBytes(int fieldNum, byte[] val)
protected abstract void	SchemaTuple.generatedCodeSetDataBag(int fieldNum, DataBag val)
protected abstract void	SchemaTuple.generatedCodeSetDateTime(int fieldNum, org.joda.time.DateTime val)
protected abstract void	SchemaTuple.generatedCodeSetDouble(int fieldNum, double val)
abstract void	SchemaTuple.generatedCodeSetField(int fieldNum, Object val)
protected abstract void	SchemaTuple.generatedCodeSetFloat(int fieldNum, float val)
protected abstract void	SchemaTuple.generatedCodeSetInt(int fieldNum, int val)
protected abstract void	SchemaTuple.generatedCodeSetIterator(Iterator<Object> l)
protected abstract void	SchemaTuple.generatedCodeSetLong(int fieldNum, long val)
protected abstract void	SchemaTuple.generatedCodeSetMap(int fieldNum, Map<String,Object> val)
protected abstract void	SchemaTuple.generatedCodeSetString(int fieldNum, String val)
protected abstract void	SchemaTuple.generatedCodeSetTuple(int fieldNum, Tuple val)
Object	UnlimitedNullTuple.get(int fieldNum)
Object	Tuple.get(int fieldNum) Get the value in a given field.
Object	TargetedTuple.get(int fieldNum)
Object	SchemaTuple.get(int fieldNum)
Object	DefaultTuple.get(int fieldNum) Get the value in a given field.
Object	AppendableSchemaTuple.get(int fieldNum)
protected Object	AppendableSchemaTuple.getAppendedField(int i)
BigDecimal	TypeAwareTuple.getBigDecimal(int idx)
BigDecimal	SchemaTuple.getBigDecimal(int fieldNum)
BigInteger	TypeAwareTuple.getBigInteger(int idx)
BigInteger	SchemaTuple.getBigInteger(int fieldNum)
boolean	TypeAwareTuple.getBoolean(int idx)
boolean	SchemaTuple.getBoolean(int fieldNum)
byte[]	TypeAwareTuple.getBytes(int idx)
byte[]	SchemaTuple.getBytes(int fieldNum)
DataBag	TypeAwareTuple.getDataBag(int idx)
DataBag	SchemaTuple.getDataBag(int fieldNum)
org.joda.time.DateTime	TypeAwareTuple.getDateTime(int idx)
org.joda.time.DateTime	SchemaTuple.getDateTime(int fieldNum)
double	TypeAwareTuple.getDouble(int idx)
double	SchemaTuple.getDouble(int fieldNum)
float	TypeAwareTuple.getFloat(int idx)
float	SchemaTuple.getFloat(int fieldNum)
abstract byte	SchemaTuple.getGeneratedCodeFieldType(int fieldNum)
int	TypeAwareTuple.getInt(int idx)
int	SchemaTuple.getInt(int fieldNum)
long	TypeAwareTuple.getLong(int idx)
long	SchemaTuple.getLong(int fieldNum)
Map<String,Object>	TypeAwareTuple.getMap(int idx)
Map<String,Object>	SchemaTuple.getMap(int fieldNum)
String	TypeAwareTuple.getString(int idx)
String	SchemaTuple.getString(int fieldNum)
Tuple	TypeAwareTuple.getTuple(int idx)
Tuple	SchemaTuple.getTuple(int fieldNum)
byte	Tuple.getType(int fieldNum) Find the type of a given field.
byte	TargetedTuple.getType(int fieldNum)
byte	SchemaTuple.getType(int fieldNum)
byte	AppendableSchemaTuple.getType(int fieldNum)
byte	AbstractTuple.getType(int fieldNum) Find the type of a given field.
protected Object	SchemaTuple.getTypeAwareBase(int fieldNum, String type)
protected Object	AppendableSchemaTuple.getTypeAwareBase(int fieldNum, String type)
abstract boolean	SchemaTuple.isGeneratedCodeFieldNull(int fieldNum)
boolean	Tuple.isNull(int fieldNum) Find out if a given field is null.
boolean	SchemaTuple.isNull(int fieldNum)
boolean	AppendableSchemaTuple.isNull(int fieldNum)
boolean	AbstractTuple.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) Expects binInterSedes data types (NOT DataType types!)
void	UnlimitedNullTuple.set(int fieldNum, Object val)
void	Tuple.set(int fieldNum, Object val) Set the value in a given field.
void	TargetedTuple.set(int fieldNum, Object val)
void	SchemaTuple.set(int fieldNum, Object val)
void	DefaultTuple.set(int fieldNum, Object val) Set the value in a given field.
void	AppendableSchemaTuple.set(int fieldNum, Object val)
SchemaTuple<T>	SchemaTuple.set(List<Object> l)
SchemaTuple<T>	AppendableSchemaTuple.set(List<Object> l)
SchemaTuple<T>	SchemaTuple.set(SchemaTuple<?> t)
protected SchemaTuple<T>	SchemaTuple.set(SchemaTuple<?> t, boolean checkType)
protected SchemaTuple<T>	AppendableSchemaTuple.set(SchemaTuple<?> t, boolean checkType)
SchemaTuple<T>	SchemaTuple.set(Tuple t)
protected SchemaTuple<T>	SchemaTuple.set(Tuple t, boolean checkType)
void	TypeAwareTuple.setBigDecimal(int idx, BigDecimal val)
void	SchemaTuple.setBigDecimal(int fieldNum, BigDecimal val)
void	TypeAwareTuple.setBigInteger(int idx, BigInteger val)
void	SchemaTuple.setBigInteger(int fieldNum, BigInteger val)
void	TypeAwareTuple.setBoolean(int idx, boolean val)
void	SchemaTuple.setBoolean(int fieldNum, boolean val)
void	TypeAwareTuple.setBytes(int idx, byte[] val)
void	SchemaTuple.setBytes(int fieldNum, byte[] val)
void	TypeAwareTuple.setDataBag(int idx, DataBag val)
void	SchemaTuple.setDataBag(int fieldNum, DataBag val)
void	TypeAwareTuple.setDateTime(int idx, org.joda.time.DateTime val)
void	SchemaTuple.setDateTime(int fieldNum, org.joda.time.DateTime val)
void	TypeAwareTuple.setDouble(int idx, double val)
void	SchemaTuple.setDouble(int fieldNum, double val)
void	TypeAwareTuple.setFloat(int idx, float val)
void	SchemaTuple.setFloat(int fieldNum, float val)
void	TypeAwareTuple.setInt(int idx, int val)
void	SchemaTuple.setInt(int fieldNum, int val)
void	TypeAwareTuple.setLong(int idx, long val)
void	SchemaTuple.setLong(int fieldNum, long val)
void	TypeAwareTuple.setMap(int idx, Map<String,Object> val)
void	SchemaTuple.setMap(int fieldNum, Map<String,Object> val)
void	TypeAwareTuple.setString(int idx, String val)
void	SchemaTuple.setString(int fieldNum, String val)
void	TypeAwareTuple.setTuple(int idx, Tuple val)
void	SchemaTuple.setTuple(int fieldNum, Tuple val)
protected void	SchemaTuple.setTypeAwareBase(int fieldNum, Object val, String type)
protected void	AppendableSchemaTuple.setTypeAwareBase(int fieldNum, Object val, String type)
static DataBag	DataType.toBag(Object o) If this object is a bag, return it as a bag.
static BigDecimal	DataType.toBigDecimal(Object o)
static BigDecimal	DataType.toBigDecimal(Object o, byte type)
static BigInteger	DataType.toBigInteger(Object o)
static BigInteger	DataType.toBigInteger(Object o, byte type)
static Boolean	DataType.toBoolean(Object o)
static Boolean	DataType.toBoolean(Object o, byte type) Force a data object to a Boolean, if possible.
static byte[]	DataType.toBytes(Object o)
static byte[]	DataType.toBytes(Object o, byte type)
static org.joda.time.DateTime	DataType.toDateTime(Object o)
static org.joda.time.DateTime	DataType.toDateTime(Object o, byte type) Force a data object to a DateTime, if possible.
String	Tuple.toDelimitedString(String delim) Write a tuple of values into a string.
String	AbstractTuple.toDelimitedString(String delim) Write a tuple of 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

Modifier and Type	Method and Description
void	PigContext.connect()
ExecutableManager	PigContext.createExecutableManager() Create a new ExecutableManager depending on the ExecType.
static <T> T	PigContext.instantiateObjectFromParams(org.apache.hadoop.conf.Configuration conf, String classParamKey, String argParamKey, Class<T> clazz) A common Pig pattern for initializing objects via system properties is to support passing something like this on the command line: -Dpig.notification.listener=MyClass -Dpig.notification.listener.arg=myConstructorStringArg This method will properly initialize the class with the args, if they exist.

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

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

Modifier and Type	Method and Description
void	SampleLoader.computeSamples(ArrayList<Pair<FileSpec,Boolean>> inputs, PigContext pc)
Object	IdentityColumn.exec(Tuple input)

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

Constructor and Description
StreamingUDF(String language, String filePath, String funcName, String outputSchemaString, String schemaLineNumber, String execType, String isIllustrate)

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

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

Modifier and Type	Class and Description
class	StreamingUDFException

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

Modifier and Type	Method and Description
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

Constructor and Description
FileInputHandler(StreamingCommand.HandleSpec handleSpec)
FileOutputHandler(StreamingCommand.HandleSpec handleSpec)

Uses of ExecException in org.apache.pig.impl.util.avro

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

Modifier and Type	Method and Description
Object	AvroTupleWrapper.get(int pos)
static byte	AvroStorageSchemaConversionUtilities.getPigType(org.apache.avro.Schema s) Determines the pig object type of the Avro schema.
byte	AvroTupleWrapper.getType(int arg0)
boolean	AvroTupleWrapper.isNull(int arg0)
void	AvroTupleWrapper.set(int arg0, Object arg1)
String	AvroTupleWrapper.toDelimitedString(String arg0)

Uses of ExecException in org.apache.pig.pen

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

Modifier and Type	Method and Description
Map<LOLoad,DataBag>	AugmentBaseDataVisitor.getNewBaseData()

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

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

Modifier and Type	Method and Description
Object	ExampleTuple.get(int fieldNum)
byte	ExampleTuple.getType(int fieldNum)
boolean	ExampleTuple.isNull(int fieldNum)
void	ExampleTuple.set(int fieldNum, Object val)

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

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

Modifier and Type	Method and Description
protected static Tuple	ExtremalTupleByNthField.extreme(int pind, int psign, Tuple input, PigProgressable reporter)
protected static Tuple	MaxTupleBy1stField.max(DataBag values, 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

Constructor and Description
ExtremalTupleByNthField() Constructors
ExtremalTupleByNthField(String fieldIndexString)
ExtremalTupleByNthField(String fieldIndexString, String order)
HelperClass()
HelperClass(String fieldIndexString)
HelperClass(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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
Map<String,List<PigStats>>	ScriptEngine.run(PigContext pigContext, String scriptFile) Runs a script file.

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

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

Modifier and Type	Method and Description
static Object	GroovyUtils.groovyToPig(Object groovyObject) Converts an object created on the Groovy side to its Pig counterpart.
static Object	GroovyUtils.pigToGroovy(Object pigObject) Converts an object created on the Pig side to its Groovy counterpart.

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

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

Modifier and Type	Method and Description
void	RubyDataBag.add(org.jruby.runtime.ThreadContext context, org.jruby.runtime.builtin.IRubyObject[] args) The add method accepts a varargs argument; each argument can be either a random object, a DataBag, or a RubyArray.
org.jruby.runtime.builtin.IRubyObject	RubyDataBag.each(org.jruby.runtime.ThreadContext context, org.jruby.runtime.Block block) This is an implementation of the each method which opens up the Enumerable interface, and makes it very convenient to iterate over the elements of a DataBag.
org.jruby.runtime.builtin.IRubyObject	RubyDataBag.flatten(org.jruby.runtime.ThreadContext context, org.jruby.runtime.Block block) This is a convenience method which will run the given block on the first element of each tuple contained.
static <T> org.jruby.RubyHash	PigJrubyLibrary.pigToRuby(org.jruby.Ruby ruby, Map<T,?> object) A type specific conversion routine for Pig Maps.
static org.jruby.runtime.builtin.IRubyObject	PigJrubyLibrary.pigToRuby(org.jruby.Ruby ruby, Object object) This is the method which provides conversion from Pig to Ruby.
static org.jruby.RubyArray	PigJrubyLibrary.pigToRuby(org.jruby.Ruby ruby, Tuple object) A type specific conversion routine.
static Object	PigJrubyLibrary.rubyToPig(org.jruby.runtime.builtin.IRubyObject rbObject) This method facilitates conversion from Ruby objects to Pig objects.
static Tuple	PigJrubyLibrary.rubyToPig(org.jruby.RubyArray rbObject) A type specific conversion routine.
static Map<String,?>	PigJrubyLibrary.rubyToPig(org.jruby.RubyHash rbObject) A type specific conversion routine.

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

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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Constructor and Description
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

Constructor and Description
Grunt(BufferedReader in, PigContext pigContext)