public class POLocalRearrangeTez extends POLocalRearrange implements TezOutput
PhysicalOperator.OriginalLocation
Modifier and Type | Field and Description |
---|---|
protected boolean |
connectedToPackage |
protected boolean |
isSkewedJoin |
protected String |
outputKey |
protected org.apache.tez.runtime.library.api.KeyValueWriter |
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 |
---|
POLocalRearrangeTez(OperatorKey k) |
POLocalRearrangeTez(OperatorKey k,
int rp) |
POLocalRearrangeTez(POLocalRearrange copy) |
Modifier and Type | Method and Description |
---|---|
void |
attachOutputs(Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs,
org.apache.hadoop.conf.Configuration conf) |
POLocalRearrangeTez |
clone()
Make a deep copy of this operator.
|
boolean |
containsOutputKey(String key) |
Result |
getNextTuple()
Calls getNext on the generate operator inside the nested
physical plan.
|
protected Result |
getRearrangedTuple() |
String[] |
getTezOutputs() |
boolean |
isConnectedToPackage() |
boolean |
isSkewedJoin() |
String |
name() |
void |
replaceOutput(String oldOutputKey,
String newOutputKey) |
void |
setConnectedToPackage(boolean connectedToPackage) |
void |
setOutputKey(String outputKey) |
void |
setSkewedJoin(boolean isSkewedJoin) |
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
protected String outputKey
protected boolean connectedToPackage
protected boolean isSkewedJoin
protected transient org.apache.tez.runtime.library.api.KeyValueWriter writer
public POLocalRearrangeTez(OperatorKey k)
public POLocalRearrangeTez(OperatorKey k, int rp)
public POLocalRearrangeTez(POLocalRearrange copy)
public boolean containsOutputKey(String key)
public void setOutputKey(String outputKey)
public boolean isConnectedToPackage()
public void setConnectedToPackage(boolean connectedToPackage)
public boolean isSkewedJoin()
public void setSkewedJoin(boolean isSkewedJoin)
public String[] getTezOutputs()
getTezOutputs
in interface TezOutput
public void replaceOutput(String oldOutputKey, String newOutputKey)
replaceOutput
in interface TezOutput
public void attachOutputs(Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs, org.apache.hadoop.conf.Configuration conf) throws ExecException
attachOutputs
in interface TezOutput
ExecException
protected Result getRearrangedTuple() throws ExecException
ExecException
public Result getNextTuple() throws ExecException
POLocalRearrange
getNextTuple
in class POLocalRearrange
ExecException
public POLocalRearrangeTez clone() throws CloneNotSupportedException
POLocalRearrange
public String name()
name
in class POLocalRearrange
Copyright © 2007-2017 The Apache Software Foundation