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.jruby   
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 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
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.
 PigStats MapReduceLauncher.launchPig(PhysicalPlan php, String grpName, PigContext pc)
           
 

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)
           
protected  Result ConstantExpression.genericGetNext(Object obj, byte dataType)
           
 Result POBinCond.genericGetNext(Object obj, byte dataType)
           
protected
<T extends Number>
Result
Multiply.genericGetNext(T number, byte dataType)
           
protected
<T extends Number>
Result
Subtract.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)
           
protected
<T extends Number>
Result
Mod.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 POUserComparisonFunc.getNext(Boolean b)
           
 Result POIsNull.getNext(Boolean b)
           
 Result ConstantExpression.getNext(Boolean b)
           
 Result NotEqualToExpr.getNext(Boolean bool)
           
 Result EqualToExpr.getNext(Boolean bool)
           
 Result POMapLookUp.getNext(Boolean b)
           
 Result POAnd.getNext(Boolean b)
           
 Result LessThanExpr.getNext(Boolean bool)
           
 Result POUserFunc.getNext(Boolean b)
           
 Result POCast.getNext(Boolean b)
           
 Result POBinCond.getNext(Boolean b)
           
 Result PONot.getNext(Boolean b)
           
 Result POOr.getNext(Boolean b)
           
 Result GreaterThanExpr.getNext(Boolean bool)
           
 Result GTOrEqualToExpr.getNext(Boolean bool)
           
 Result POProject.getNext(Boolean b)
           
 Result LTOrEqualToExpr.getNext(Boolean bool)
           
 Result ComparisonOperator.getNext(Boolean b)
           
 Result PORegexp.getNext(Boolean bool)
           
 Result POUserComparisonFunc.getNext(DataBag db)
           
 Result ConstantExpression.getNext(DataBag db)
           
 Result POMapLookUp.getNext(DataBag db)
           
 Result ExpressionOperator.getNext(DataBag db)
           
 Result PORelationToExprProject.getNext(DataBag db)
           
 Result POUserFunc.getNext(DataBag db)
           
 Result POCast.getNext(DataBag bag)
           
 Result POBinCond.getNext(DataBag db)
           
 Result POProject.getNext(DataBag db)
           
 Result ComparisonOperator.getNext(DataBag db)
           
 Result POUserComparisonFunc.getNext(DataByteArray ba)
           
 Result ConstantExpression.getNext(DataByteArray ba)
           
 Result POMapLookUp.getNext(DataByteArray ba)
           
 Result POUserFunc.getNext(DataByteArray ba)
           
 Result POCast.getNext(DataByteArray dba)
           
 Result POBinCond.getNext(DataByteArray ba)
           
 Result POProject.getNext(DataByteArray ba)
           
 Result ComparisonOperator.getNext(DataByteArray ba)
           
 Result POUserComparisonFunc.getNext(Double d)
           
 Result Multiply.getNext(Double d)
           
 Result Subtract.getNext(Double d)
           
 Result ConstantExpression.getNext(Double d)
           
 Result POMapLookUp.getNext(Double d)
           
 Result Divide.getNext(Double d)
           
 Result Add.getNext(Double d)
           
 Result POUserFunc.getNext(Double d)
           
 Result POCast.getNext(Double d)
           
 Result POBinCond.getNext(Double d)
           
 Result PONegative.getNext(Double d)
           
 Result POProject.getNext(Double d)
           
 Result ComparisonOperator.getNext(Double d)
           
 Result POUserComparisonFunc.getNext(Float f)
           
 Result Multiply.getNext(Float f)
           
 Result Subtract.getNext(Float f)
           
 Result ConstantExpression.getNext(Float f)
           
 Result POMapLookUp.getNext(Float f)
           
 Result Divide.getNext(Float f)
           
 Result Add.getNext(Float f)
           
 Result POUserFunc.getNext(Float f)
           
 Result POCast.getNext(Float f)
           
 Result POBinCond.getNext(Float f)
           
 Result PONegative.getNext(Float f)
           
 Result POProject.getNext(Float f)
           
 Result ComparisonOperator.getNext(Float f)
           
 Result POUserComparisonFunc.getNext(Integer i)
           
 Result Multiply.getNext(Integer i)
           
 Result Subtract.getNext(Integer i)
           
 Result ConstantExpression.getNext(Integer i)
           
 Result POMapLookUp.getNext(Integer i)
           
 Result Divide.getNext(Integer i)
           
 Result Add.getNext(Integer i)
           
 Result Mod.getNext(Integer i)
           
 Result POUserFunc.getNext(Integer i)
           
 Result POCast.getNext(Integer i)
           
 Result POBinCond.getNext(Integer i)
           
 Result PONegative.getNext(Integer i)
           
 Result POProject.getNext(Integer i)
           
 Result ComparisonOperator.getNext(Integer i)
           
 Result POUserComparisonFunc.getNext(Long l)
           
 Result Multiply.getNext(Long l)
           
 Result Subtract.getNext(Long l)
           
 Result ConstantExpression.getNext(Long l)
           
 Result POMapLookUp.getNext(Long l)
           
 Result Divide.getNext(Long l)
           
 Result Add.getNext(Long l)
           
 Result Mod.getNext(Long i)
           
 Result POUserFunc.getNext(Long l)
           
 Result POCast.getNext(Long l)
           
 Result POBinCond.getNext(Long l)
           
 Result PONegative.getNext(Long l)
           
 Result POProject.getNext(Long l)
           
 Result ComparisonOperator.getNext(Long l)
           
 Result POUserComparisonFunc.getNext(Map m)
           
 Result ConstantExpression.getNext(Map m)
           
 Result POMapLookUp.getNext(Map m)
           
 Result POUserFunc.getNext(Map m)
           
 Result POCast.getNext(Map m)
           
 Result POBinCond.getNext(Map m)
           
 Result POProject.getNext(Map m)
           
 Result ComparisonOperator.getNext(Map m)
           
 Result POUserComparisonFunc.getNext(String s)
           
 Result ConstantExpression.getNext(String s)
           
 Result POMapLookUp.getNext(String s)
           
 Result POUserFunc.getNext(String s)
           
 Result POCast.getNext(String str)
           
 Result POBinCond.getNext(String s)
           
 Result POProject.getNext(String s)
           
 Result ComparisonOperator.getNext(String s)
           
 Result POUserComparisonFunc.getNext(Tuple in)
           
 Result ConstantExpression.getNext(Tuple t)
           
 Result POMapLookUp.getNext(Tuple t)
           
 Result POUserFunc.getNext(Tuple tIn)
           
 Result POCast.getNext(Tuple t)
           
 Result POBinCond.getNext(Tuple t)
           
 Result POProject.getNext(Tuple t)
          Asked for Tuples.
 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 POMapLookUp.processInput()
           
 Result POUserFunc.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 POMergeCogroup.getNext(Tuple t)
           
 Result POPartialAgg.getNext(Tuple t)
           
 Result POSplit.getNext(Tuple t)
           
 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 POStore.getNext(Tuple t)
           
 Result POFilter.getNext(Tuple t)
          Attaches the proccesed input tuple to the expression plan and checks if comparison operator returns a true.
 Result POFRJoin.getNext(Tuple t)
           
 Result POLocalRearrange.getNext(Tuple t)
          Calls getNext on the generate operator inside the nested physical plan.
 Result POJoinPackage.getNext(Tuple t)
          Calls getNext to get next ForEach result.
 Result POStream.getNext(Tuple t)
           
 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 PODemux.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 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 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 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 PODistinct.getNext(Tuple t)
           
 Result POMergeJoin.getNext(Tuple t)
           
 Result POPartitionRearrange.getNext(Tuple t)
          Calls getNext on the generate operator inside the nested physical plan.
 Result POSort.getNext(Tuple t)
           
 Result POGlobalRearrange.getNext(Tuple t)
           
 Result POCross.getNext(Tuple t)
           
 Result POPreCombinerLocalRearrange.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 POCombinerPackage.getNext(Tuple t)
           
 Result POMultiQueryPackage.getNext(Tuple t)
          Constructs the output tuple from the inputs.
 Result POCollectedGroup.getNext(Tuple t)
           
 Result POSortedDistinct.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 FloatAvg.combine(DataBag values)
           
protected static Tuple AVG.combine(DataBag values)
           
protected static Tuple LongAvg.combine(DataBag values)
           
protected static Tuple DoubleAvg.combine(DataBag values)
           
protected static Tuple IntAvg.combine(DataBag values)
           
protected static long FloatAvg.count(Tuple input)
           
protected static long AVG.count(Tuple input)
           
protected static long LongAvg.count(Tuple input)
           
protected static long DoubleAvg.count(Tuple input)
           
protected static long IntAvg.count(Tuple input)
           
protected static Double MAX.max(Tuple input)
           
protected static String StringMax.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 Long LongMax.max(Tuple input)
           
protected static Double MAX.maxDoubles(Tuple input)
           
protected static Double DoubleMin.min(Tuple input)
           
protected static Long LongMin.min(Tuple input)
           
protected static Integer IntMin.min(Tuple input)
           
protected static String StringMin.min(Tuple input)
           
protected static Double MIN.min(Tuple input)
           
protected static Float FloatMin.min(Tuple input)
           
protected static Double MIN.minDoubles(Tuple input)
           
protected static Double FloatAvg.sum(Tuple input)
           
protected static Double AVG.sum(Tuple input)
           
protected static Long LongSum.sum(Tuple input)
           
protected static Double FloatSum.sum(Tuple input)
           
protected static Double SUM.sum(Tuple input)
           
protected static Long COUNT_STAR.sum(Tuple input)
           
protected static Double DoubleSum.sum(Tuple input)
           
protected static Long LongAvg.sum(Tuple input)
           
protected static Double DoubleAvg.sum(Tuple input)
           
protected static Long IntAvg.sum(Tuple input)
           
protected static Long IntSum.sum(Tuple input)
           
protected static Long COUNT.sum(Tuple input)
           
protected static Double FloatSum.sumDoubles(Tuple input)
           
protected static Double SUM.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 DefaultTuple.get(int fieldNum)
          Get the value in a given field.
 Object TargetedTuple.get(int fieldNum)
           
 byte Tuple.getType(int fieldNum)
          Find the type of a given field.
 byte DefaultTuple.getType(int fieldNum)
          Find the type of a given field.
 byte TargetedTuple.getType(int fieldNum)
           
 boolean Tuple.isNull(int fieldNum)
          Find out if a given field is null.
 boolean DefaultTuple.isNull(int fieldNum)
          Find out if a given field is null.
 boolean TargetedTuple.isNull(int fieldNum)
           
 Object InterSedes.readDatum(DataInput in)
          Get the next object from DataInput in
 Object BinInterSedes.readDatum(DataInput in)
           
static Object DataReaderWriter.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.
 Object BinInterSedes.readDatum(DataInput in, byte type)
           
static Object DataReaderWriter.readDatum(DataInput in, byte type)
           
 void Tuple.set(int fieldNum, Object val)
          Set the value in a given field.
 void DefaultTuple.set(int fieldNum, Object val)
          Set the value in a given field.
 void TargetedTuple.set(int fieldNum, Object val)
           
static DataBag DataType.toBag(Object o)
          If this object is a bag, return it as a bag.
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)
           
 String Tuple.toDelimitedString(String delim)
          Write a tuple of atomic values into a string.
 String DefaultTuple.toDelimitedString(String delim)
          Write a tuple of atomic values into a string.
 String TargetedTuple.toDelimitedString(String delim)
           
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.jruby
 

Methods in org.apache.pig.scripting.jruby that throw ExecException
 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
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)
           
 



Copyright © ${year} The Apache Software Foundation