public class POReduceBySpark extends POForEach
PhysicalOperator.OriginalLocation
Modifier and Type | Field and Description |
---|---|
protected POLocalRearrange |
lr |
protected POPackage |
pkg |
bags, buffer, data, earlyTermination, endOfAllInputProcessed, endOfAllInputProcessing, inpTuple, inputPlans, isToBeFlattenedArray, its, mapSideOnly, noItems, opsToBeReset, planLeafOps, processingPlan, resultTypes, tIn
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POReduceBySpark(OperatorKey k,
int rp,
List<PhysicalPlan> inp,
List<Boolean> isToBeFlattened,
POPackage pkg,
POLocalRearrange lr) |
Modifier and Type | Method and Description |
---|---|
String |
getCustomPartitioner() |
protected String |
getFlatStr() |
POLocalRearrange |
getLROp() |
POPackage |
getPKGOp() |
boolean[] |
getSecondarySortOrder() |
boolean |
isUseSecondaryKey() |
String |
name() |
void |
setCustomPartitioner(String customPartitioner) |
void |
setSecondarySortOrder(boolean[] secondarySortOrder) |
void |
setUseSecondaryKey(boolean useSecondaryKey) |
addInputPlan, attachInputToPlans, clone, createTuple, getInputPlans, getLeaves, getNextTuple, getOpsToBeReset, getPlanLeafOps, getToBeFlattened, illustratorMarkup, inProcessing, isMapSideOnly, needEndOfAllInputProcessing, processPlan, setAccumEnd, setAccumStart, setAccumulative, setInputPlans, setMapSideOnly, setOpsToBeReset, setToBeFlattened, setUpFlattens, supportsMultipleInputs, supportsMultipleOutputs, visit
addOriginalLocation, addOriginalLocation, attachInput, 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, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanup
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap
protected POLocalRearrange lr
protected POPackage pkg
public POReduceBySpark(OperatorKey k, int rp, List<PhysicalPlan> inp, List<Boolean> isToBeFlattened, POPackage pkg, POLocalRearrange lr)
public POPackage getPKGOp()
protected String getFlatStr()
public boolean isUseSecondaryKey()
public void setUseSecondaryKey(boolean useSecondaryKey)
public boolean[] getSecondarySortOrder()
public void setSecondarySortOrder(boolean[] secondarySortOrder)
public String getCustomPartitioner()
public void setCustomPartitioner(String customPartitioner)
public POLocalRearrange getLROp()
Copyright © 2007-2017 The Apache Software Foundation