public class POShuffleTezLoad extends POPackage implements TezInput
POPackage.POPackageTupleBuffer
PhysicalOperator.OriginalLocation
Modifier and Type | Field and Description |
---|---|
protected List<String> |
inputKeys |
key, keyWritable, numInputs, pkgr
alias, illustrator, input, inputAttached, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POShuffleTezLoad(POPackage pack) |
Modifier and Type | Method and Description |
---|---|
void |
addInputKey(String inputKey) |
void |
addInputsToSkip(Set<String> inputsToSkip)
Add to the list of inputs to skip download if already available in vertex cache
|
void |
attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs,
org.apache.hadoop.conf.Configuration conf)
Attach the inputs to the operator.
|
Result |
getNextTuple()
From the inputs, constructs the output tuple for this co-group in the
required format which is (key, {bag of tuples from input 1}, {bag of
tuples from input 2}, ...)
|
String[] |
getTezInputs() |
boolean |
isSkewedJoin() |
void |
replaceInput(String oldInputKey,
String newInputKey) |
void |
setInputKeys(List<String> inputKeys) |
void |
setSkewedJoins(boolean isSkewedJoin) |
boolean |
supportsMultipleInputs()
Indicates whether this operator supports multiple inputs.
|
attachInput, clone, detachInput, getNumInps, getPkgr, illustratorMarkup, name, numberOfEquivalenceClasses, setIllustrator, setNumInps, setPkgr, supportsMultipleOutputs, visit
addOriginalLocation, addOriginalLocation, attachInput, cloneHelper, clonePlans, copyAliasFrom, 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, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanup
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap
public POShuffleTezLoad(POPackage pack)
public String[] getTezInputs()
getTezInputs
in interface TezInput
public void replaceInput(String oldInputKey, String newInputKey)
replaceInput
in interface TezInput
public void addInputsToSkip(Set<String> inputsToSkip)
TezInput
addInputsToSkip
in interface TezInput
public void attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf) throws ExecException
TezInput
attachInputs
in interface TezInput
inputs
- available inputsconf
- configurationExecException
public Result getNextTuple() throws ExecException
POPackage
getNextTuple
in class POPackage
ExecException
public void addInputKey(String inputKey)
public void setSkewedJoins(boolean isSkewedJoin)
public boolean isSkewedJoin()
public boolean supportsMultipleInputs()
Operator
supportsMultipleInputs
in class POPackage
Copyright © 2007-2017 The Apache Software Foundation