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

Packages that use ExecException
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.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.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
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
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)
           
 

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 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
static byte HDataType.findTypeFromNullableWritable(PigNullableWritable o)
           
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
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
 String HJob.getAlias()
           
 org.apache.hadoop.mapred.JobConf HExecutionEngine.getExecConf(Properties properties)
           
 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()
           
 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
 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
 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
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()
           
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
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 JoinPackager.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  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 PORank.getNextTuple()
           
 Result POPreCombinerLocalRearrange.getNextTuple()
          Calls getNext on the generate operator inside the nested physical plan.
 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 index)
           
 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  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)
           
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)
           
 

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 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
 class FieldIsNullException
           
 

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
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 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 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
 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
 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
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
 class StreamingUDFException
           
 

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.impl.util.avro
 

Methods in org.apache.pig.impl.util.avro that throw ExecException
 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
 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)
           
 

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.groovy
 

Methods in org.apache.pig.scripting.groovy that throw ExecException
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
 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 © 2007-2012 The Apache Software Foundation