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.
|
Result |
getNextTuple()
Calls getNext on the generate operator inside the nested
physical plan.
|
String |
getOutputKey() |
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, 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
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 String getOutputKey()
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
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-2012 The Apache Software Foundation