public class POPartitionRearrangeTez extends POLocalRearrangeTez
PhysicalOperator.OriginalLocation
connectedToPackage, isSkewedJoin, outputKey, writer
index, inp, isCross, keyType, leafOps, mainKeyType, mFakeTuple, mIsDistinct, mTupleFactory, plans, secondaryKeyType, secondaryLeafOps, secondaryPlans
alias, illustrator, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POPartitionRearrangeTez(OperatorKey k) |
POPartitionRearrangeTez(OperatorKey k,
int rp) |
Modifier and Type | Method and Description |
---|---|
protected DataBag |
constructPROutput(java.util.List<Result> resLst,
Tuple value) |
Result |
getNextTuple()
Calls getNext on the generate operator inside the nested physical plan.
|
java.lang.String |
name() |
attachOutputs, clone, getOutputKey, getTezOutputs, isConnectedToPackage, isSkewedJoin, replaceOutput, setConnectedToPackage, setOutputKey, setSkewedJoin
attachInput, constructLROutput, deepCopyTo, getIndex, getKeyFromResult, getKeyType, getMainKeyType, getPlans, getProjectedColsMap, getSecondaryProjectedColsMap, illustratorMarkup, isCross, isDistinct, isKeyCompound, isKeyTuple, isProjectStar, isSecondaryKeyTuple, isSecondaryProjectStar, setCross, setDistinct, setIndex, setKeyType, setMultiQueryIndex, setPlans, setPlansFromCombiner, setSecondaryPlans, setStripKeyFromValue, setUseSecondaryKey, supportsMultipleInputs, supportsMultipleOutputs, visit
addOriginalLocation, addOriginalLocation, cloneHelper, copyAliasFrom, detachInput, getAlias, getAliasString, getIllustrator, getInputs, getLogger, getNext, getNextBigDecimal, getNextBigInteger, getNextBoolean, getNextDataBag, getNextDataByteArray, getNextDateTime, getNextDouble, getNextFloat, getNextInteger, getNextLong, getNextMap, getNextString, getOriginalLocations, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanup
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap
public POPartitionRearrangeTez(OperatorKey k)
public POPartitionRearrangeTez(OperatorKey k, int rp)
public java.lang.String name()
name
in class POLocalRearrangeTez
public Result getNextTuple() throws ExecException
getNextTuple
in class POLocalRearrangeTez
ExecException
protected DataBag constructPROutput(java.util.List<Result> resLst, Tuple value) throws ExecException
ExecException
Copyright © 2007-2012 The Apache Software Foundation