public class TernaryOp extends MultiThreadedHop
quantile (<n-1-matrix>, <n-1-matrix>, <literal>): quantile (A, w, 0.5)
quantile (<n-1-matrix>, <n-1-matrix>, <scalar>): quantile (A, w, s)
interquantile (<n-1-matrix>, <n-1-matrix>, <scalar>): interquantile (A, w, s)
Keep in mind, that we also have binaries for it w/o weights.
quantile (A, 0.5)
quantile (A, s)
interquantile (A, s)
Note: this hop should be called AggTernaryOp in consistency with AggUnaryOp and AggBinaryOp;
however, since there does not exist a real TernaryOp yet - we can leave it as is for now.
CTABLE op takes 2 extra inputs with target dimensions for padding and pruning.Modifier and Type | Field and Description |
---|---|
static boolean |
ALLOW_CTABLE_SEQUENCE_REWRITES |
_beginColumn, _beginLine, _endColumn, _endLine, _filename, _text, CPThreshold
Constructor and Description |
---|
TernaryOp(String l,
Types.DataType dt,
Types.ValueType vt,
Types.OpOp3 o,
Hop inp1,
Hop inp2,
Hop inp3) |
TernaryOp(String l,
Types.DataType dt,
Types.ValueType vt,
Types.OpOp3 o,
Hop inp1,
Hop inp2,
Hop inp3,
Hop inp4,
Hop inp5,
Hop inp6) |
Modifier and Type | Method and Description |
---|---|
boolean |
allowsAllExecTypes() |
void |
checkArity()
Check whether this Hop has a correct number of inputs.
|
Object |
clone() |
boolean |
compare(Hop that) |
Lop |
constructLops() |
Types.OpOp3 |
getOp() |
String |
getOpString() |
boolean |
isCTableReshapeRewriteApplicable(Types.ExecType et,
Ctable.OperationTypes opType) |
boolean |
isGPUEnabled()
In memory-based optimizer mode (see OptimizerUtils.isMemoryBasedOptLevel()),
the exectype is determined by checking this method as well as memory budget of this Hop.
|
boolean |
isMatrixIgnoreZeroRewriteApplicable()
Used for (1) constructing CP lops (hop-lop rewrite), and (2) in order to determine
if dag split after removeEmpty necessary (#2 is precondition for #1).
|
boolean |
isMultiThreadedOpType() |
void |
refreshSizeInformation()
Update the output size information for this hop.
|
void |
setDisjointInputs(boolean flag) |
getMaxNumThreads, setMaxNumThreads
addAllInputs, addInput, checkAndSetForcedPlatform, checkAndSetInvalidCPDimsAndSize, clearMemEstimate, colsKnown, computeBoundsInformation, computeBoundsInformation, computeBoundsInformation, computeMemEstimate, computeSizeInformation, computeSizeInformation, computeSizeInformation, constructAndSetLopsDataFlowProperties, createOffsetLop, dimsKnown, dimsKnown, dimsKnownAny, getBeginColumn, getBeginLine, getBlocksize, getDataCharacteristics, getDataType, getDim, getDim1, getDim2, getEndColumn, getEndLine, getExecType, getFilename, getForcedExecType, getHopID, getInput, getInput, getInputMemEstimate, getInputOutputSize, getIntermediateMemEstimate, getLength, getLops, getMemEstimate, getName, getNnz, getOutputMemEstimate, getParent, getPrivacy, getSparsity, getSpBroadcastSize, getText, getUpdateType, getValueType, hasFederatedOutput, hasMatrixInputWithDifferentBlocksizes, hasValidCPDimsAndSize, isFederated, isFederatedOutput, isMatrix, isMemEstimated, isOutputEmptyBlocks, isScalar, isTransposeSafe, isVisited, printErrorLocation, refreshColsParameterInformation, refreshColsParameterInformation, refreshMemEstimates, refreshRowsParameterInformation, refreshRowsParameterInformation, requiresCheckpoint, requiresCompression, requiresLineageCaching, requiresReblock, requiresRecompile, resetExecType, resetRecompilationFlag, resetRecompilationFlag, resetVisitStatus, resetVisitStatus, resetVisitStatus, resetVisitStatusForced, rowsKnown, setBeginColumn, setBeginLine, setBlocksize, setDataType, setDim, setDim1, setDim2, setEndColumn, setEndLine, setFilename, setForcedExecType, setLops, setMemEstimate, setName, setNnz, setOutputEmptyBlocks, setParseInfo, setPrivacy, setRequiresCheckpoint, setRequiresCompression, setRequiresDeCompression, setRequiresLineageCaching, setRequiresReblock, setRequiresRecompile, setText, setUpdateType, setValueType, setVisited, setVisited, toString
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
ctxAndFilenameToParseInfo
public TernaryOp(String l, Types.DataType dt, Types.ValueType vt, Types.OpOp3 o, Hop inp1, Hop inp2, Hop inp3)
public TernaryOp(String l, Types.DataType dt, Types.ValueType vt, Types.OpOp3 o, Hop inp1, Hop inp2, Hop inp3, Hop inp4, Hop inp5, Hop inp6)
public void checkArity()
Hop
checkArity
in class Hop
public Types.OpOp3 getOp()
public void setDisjointInputs(boolean flag)
public boolean isGPUEnabled()
Hop
isGPUEnabled
in class Hop
public boolean isMultiThreadedOpType()
isMultiThreadedOpType
in class MultiThreadedHop
public Lop constructLops()
constructLops
in class Hop
public String getOpString()
getOpString
in class Hop
public boolean allowsAllExecTypes()
allowsAllExecTypes
in class Hop
public void refreshSizeInformation()
Hop
refreshSizeInformation
in class Hop
public Object clone() throws CloneNotSupportedException
clone
in class Hop
CloneNotSupportedException
public boolean isMatrixIgnoreZeroRewriteApplicable()
public boolean isCTableReshapeRewriteApplicable(Types.ExecType et, Ctable.OperationTypes opType)
Copyright © 2021 The Apache Software Foundation. All rights reserved.