Overview  Package  Class   Use  Tree  Deprecated  Index  Help 
 PREV   NEXT FRAMES    NO FRAMES    

Uses of Class
org.apache.pig.backend.hadoop.executionengine.physicalLayer.Result

Packages that use Result
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   
 

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

Fields in org.apache.pig.backend.hadoop.executionengine.physicalLayer declared as Result
protected  Result PhysicalOperator.res
           
 

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer that return Result
 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 Result in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
 

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators that return Result
protected  Result ExpressionOperator.accumChild(List<ExpressionOperator> child, byte dataType)
          Drive all the UDFs in accumulative mode
protected  Result POProject.consumeInputBag(Result input)
           
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)
           
 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()
           
 Result POUserFunc.processInput()
           
 Result POMapLookUp.processInput()
           
protected  Result POProject.processInputBag()
           
 

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators with parameters of type Result
protected  Result POProject.consumeInputBag(Result input)
           
 

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

Fields in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with type parameters of type Result
protected  BlockingQueue<Result> POStream.binaryInputQueue
           
protected  BlockingQueue<Result> POStream.binaryOutputQueue
           
 

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that return Result
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.
 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()
           
protected  Result POForEach.processPlan()
           
 

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that return types with arguments of type Result
 BlockingQueue<Result> POStream.getBinaryInputQueue()
           
 BlockingQueue<Result> POStream.getBinaryOutputQueue()
           
 

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with parameters of type Result
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.
 

Method parameters in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with type arguments of type Result
protected  Tuple POLocalRearrange.constructLROutput(List<Result> resLst, List<Result> secondaryResLst, Tuple value)
           
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  Object POLocalRearrange.getKeyFromResult(List<Result> resLst, byte type)
           
 

Overview  Package  Class   Use  Tree  Deprecated  Index  Help 
 PREV   NEXT FRAMES    NO FRAMES    
Copyright © 2007-2012 The Apache Software Foundation