public class POPartitionRearrangeTez extends POLocalRearrangeTez
PhysicalOperator.OriginalLocation
connectedToPackage, isSkewedJoin, outputKey, writer
index, inp, isCross, keyType, leafOps, mainKeyType, mFakeTuple, mIsDistinct, plans, secondaryKeyType, secondaryLeafOps, secondaryPlans
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, 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 |
---|---|
POPartitionRearrangeTez |
clone()
Make a deep copy of this operator.
|
protected DataBag |
constructPROutput(List<Result> resLst,
Tuple value) |
Result |
getNextTuple()
Calls getNext on the generate operator inside the nested physical plan.
|
String |
name() |
attachOutputs, containsOutputKey, getRearrangedTuple, getTezOutputs, isConnectedToPackage, isSkewedJoin, replaceOutput, setConnectedToPackage, setOutputKey, setSkewedJoin
attachInput, constructLROutput, 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, clonePlans, copyAliasFrom, detachInput, getAlias, getAliasString, getIllustrator, getInputs, getLogger, getNext, getNextBigDecimal, getNextBigInteger, getNextBoolean, getNextDataBag, getNextDataByteArray, getNextDateTime, getNextDouble, getNextFloat, getNextInteger, getNextLong, getNextMap, getNextString, getOriginalLocations, getParentPlan, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isEndOfAllInput, 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 String name()
name
in class POLocalRearrangeTez
public Result getNextTuple() throws ExecException
getNextTuple
in class POLocalRearrangeTez
ExecException
protected DataBag constructPROutput(List<Result> resLst, Tuple value) throws ExecException
ExecException
public POPartitionRearrangeTez clone() throws CloneNotSupportedException
POLocalRearrange
Copyright © 2007-2017 The Apache Software Foundation