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

Packages that use Result

Package	Description
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.tez.plan.operator

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

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

Modifier and Type	Field and Description
protected Result	PhysicalOperator.res
protected static Result	PhysicalOperator.RESULT_EMPTY
protected static Result	PhysicalOperator.RESULT_EOP

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer that return Result

Modifier and Type	Method and Description
Result	PhysicalOperator.getNext(byte dataType) Implementations that call into the different versions of getNext are often identical, differing only in the signature of the getNext() call they make.
Result	PhysicalOperator.getNextBigDecimal()
Result	PhysicalOperator.getNextBigInteger()
Result	PhysicalOperator.getNextBoolean()
Result	PhysicalOperator.getNextDataBag()
Result	PhysicalOperator.getNextDataByteArray()
Result	PhysicalOperator.getNextDateTime()
Result	PhysicalOperator.getNextDouble()
Result	PhysicalOperator.getNextFloat()
Result	PhysicalOperator.getNextInteger()
Result	PhysicalOperator.getNextLong()
Result	PhysicalOperator.getNextMap()
Result	PhysicalOperator.getNextString()
Result	PhysicalOperator.getNextTuple()
Result	PhysicalOperator.processInput() A generic method for parsing input that either returns the attached input if it exists or fetches it from its predecessor.

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

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators that return Result

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

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

Modifier and Type	Field and Description
protected Result	POLocalRearrange.inp

Fields in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with type parameters of type Result

Modifier and Type	Field and Description
protected BlockingQueue<Result>	POStream.binaryInputQueue
protected BlockingQueue<Result>	POStream.binaryOutputQueue

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that return Result

Modifier and Type	Method and Description
protected Result	POCounter.addCounterValue(Result input) Add current task id and local counter value.
Result	PORank.addRank(Result input) Reads the output tuple from POCounter and the cumulative sum previously calculated.
Result	Packager.getNext()
Result	MultiQueryPackager.getNext() Constructs the output tuple from the inputs.
Result	LitePackager.getNext() Similar to POPackage.getNext except that only one input is expected with index 0 and ReadOnceBag is used instead of DefaultDataBag.
Result	JoinPackager.getNext() Calls getNext to get next ForEach result.
Result	CombinerPackager.getNext()
Result	POStream.getNextHelper(Tuple t)
Result	POUnion.getNextTuple() The code below, tries to follow our single threaded shared execution model with execution being passed around each non-drained input
Result	POStream.getNextTuple()
Result	POStore.getNextTuple()
Result	POSplit.getNextTuple()
Result	POSortedDistinct.getNextTuple()
Result	POSort.getNextTuple()
Result	POReservoirSample.getNextTuple()
Result	PORank.getNextTuple()
Result	POPreCombinerLocalRearrange.getNextTuple() Calls getNext on the generate operator inside the nested physical plan.
Result	POPoissonSample.getNextTuple()
Result	POPartitionRearrange.getNextTuple() Calls getNext on the generate operator inside the nested physical plan.
Result	POPartialAgg.getNextTuple()
Result	POPackage.getNextTuple() From the inputs, constructs the output tuple for this co-group in the required format which is (key, {bag of tuples from input 1}, {bag of tuples from input 2}, ...)
Result	POOptimizedForEach.getNextTuple() Calls getNext on the generate operator inside the nested physical plan and returns it maintaining an additional state to denote the begin and end of the nested plan processing.
Result	POMergeJoin.getNextTuple()
Result	POMergeCogroup.getNextTuple()
Result	POLocalRearrange.getNextTuple() Calls getNext on the generate operator inside the nested physical plan.
Result	POLoad.getNextTuple() The main method used by this operator's successor to read tuples from the specified file using the specified load function.
Result	POLimit.getNextTuple() Counts the number of tuples processed into static variable soFar, if the number of tuples processed reach the limit, return EOP; Otherwise, return the tuple
Result	POForEach.getNextTuple() Calls getNext on the generate operator inside the nested physical plan and returns it maintaining an additional state to denote the begin and end of the nested plan processing.
Result	POFilter.getNextTuple() Attaches the proccesed input tuple to the expression plan and checks if comparison operator returns a true.
Result	POFRJoin.getNextTuple()
Result	PODistinct.getNextTuple()
Result	PODemux.getNextTuple()
Result	POCross.getNextTuple()
Result	POCounter.getNextTuple()
Result	POCollectedGroup.getNextTuple()
protected Result	POForEach.processPlan()

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that return types with arguments of type Result

Modifier and Type	Method and Description
BlockingQueue<Result>	POStream.getBinaryInputQueue()
BlockingQueue<Result>	POStream.getBinaryOutputQueue()

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with parameters of type Result

Modifier and Type	Method and Description
protected Result	POCounter.addCounterValue(Result input) Add current task id and local counter value.
Result	PORank.addRank(Result input) Reads the output tuple from POCounter and the cumulative sum previously calculated.

Method parameters in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with type arguments of type Result

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

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

Methods in org.apache.pig.backend.hadoop.executionengine.tez.plan.operator that return Result

Modifier and Type	Method and Description
Result	POValueOutputTez.getNextTuple()
Result	POValueInputTez.getNextTuple()
Result	POStoreTez.getNextTuple()
Result	POSimpleTezLoad.getNextTuple() Previously, we reused the same Result object for all results, but we found certain operators (e.g.
Result	POShuffledValueInputTez.getNextTuple()
Result	POShuffleTezLoad.getNextTuple()
Result	PORankTez.getNextTuple()
Result	POPartitionRearrangeTez.getNextTuple() Calls getNext on the generate operator inside the nested physical plan.
Result	POLocalRearrangeTez.getNextTuple()
Result	POIdentityInOutTez.getNextTuple()
Result	POCounterTez.getNextTuple()
Result	POCounterStatsTez.getNextTuple()

Method parameters in org.apache.pig.backend.hadoop.executionengine.tez.plan.operator with type arguments of type Result

Modifier and Type	Method and Description
protected DataBag	POPartitionRearrangeTez.constructPROutput(List<Result> resLst, Tuple value)