public class POPartitionRearrange extends POLocalRearrange
PhysicalOperator.OriginalLocation
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 |
---|
POPartitionRearrange(OperatorKey k) |
POPartitionRearrange(OperatorKey k,
int rp) |
POPartitionRearrange(OperatorKey k,
int rp,
List<PhysicalOperator> inp) |
POPartitionRearrange(OperatorKey k,
List<PhysicalOperator> inp) |
Modifier and Type | Method and Description |
---|---|
POPartitionRearrange |
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.
|
PigContext |
getPigContext() |
String |
name() |
void |
setPigContext(PigContext pigContext) |
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 POPartitionRearrange(OperatorKey k)
public POPartitionRearrange(OperatorKey k, int rp)
public POPartitionRearrange(OperatorKey k, List<PhysicalOperator> inp)
public POPartitionRearrange(OperatorKey k, int rp, List<PhysicalOperator> inp)
public String name()
name
in class POLocalRearrange
public Result getNextTuple() throws ExecException
getNextTuple
in class POLocalRearrange
ExecException
protected DataBag constructPROutput(List<Result> resLst, Tuple value) throws ExecException
ExecException
public void setPigContext(PigContext pigContext)
pigContext
- the pigContext to setpublic PigContext getPigContext()
public POPartitionRearrange clone() throws CloneNotSupportedException
Copyright © 2007-2017 The Apache Software Foundation