Package org.apache.sysds.hops

Class MultiThreadedHop

java.lang.Object

org.apache.sysds.hops.Hop

org.apache.sysds.hops.MultiThreadedHop

All Implemented Interfaces:

ParseInfo

Direct Known Subclasses:

AggBinaryOp, AggUnaryOp, BinaryOp, DataGenOp, DnnOp, FunctionOp, ParameterizedBuiltinOp, QuaternaryOp, ReorgOp, SpoofFusedOp, TernaryOp, UnaryOp

public abstract class MultiThreadedHop
extends Hop

Optional hop interface, to be implemented by multi-threaded hops.

Field Summary

Fields inherited from class org.apache.sysds.hops.Hop

_beginColumn, _beginLine, _endColumn, _endLine, _filename, _text, CPThreshold

Constructor Summary

Constructors

Constructor	Description
MultiThreadedHop()
MultiThreadedHop(String name, Types.DataType dt, Types.ValueType vt)

Method Summary

Modifier and Type	Method	Description
int	getMaxNumThreads()
abstract boolean	isMultiThreadedOpType()
void	setMaxNumThreads(int k)

Methods inherited from class org.apache.sysds.hops.Hop

activatePrefetch, addAllInputs, addInput, allowsAllExecTypes, checkAndSetForcedPlatform, checkAndSetInvalidCPDimsAndSize, checkArity, clearMemEstimate, clone, colsKnown, compare, compressedSize, computeBoundsInformation, computeBoundsInformation, computeBoundsInformation, computeMemEstimate, computeSizeInformation, computeSizeInformation, computeSizeInformation, constructAndSetLopsDataFlowProperties, constructLops, createOffsetLop, deactivatePrefetch, dimsKnown, dimsKnown, dimsKnownAny, getBeginColumn, getBeginLine, getBlocksize, getCompressedSize, getDataCharacteristics, getDataType, getDim, getDim1, getDim2, getEndColumn, getEndLine, getExecType, getFederatedOutput, getFilename, getForcedExecType, getHopID, getInput, getInput, getInputMemEstimate, getInputMemEstimate, getInputOutputSize, getIntermediateMemEstimate, getLength, getLops, getMemEstimate, getName, getNnz, getOpString, getOutputMemEstimate, getOutputMemEstimate, getParent, getSparsity, getSpBroadcastSize, getText, getUpdateType, getValueType, hasCompressedInput, hasFederatedOutput, hasLocalOutput, hasMatrixInputWithDifferentBlocksizes, hasValidCPDimsAndSize, isCompressedOutput, isFederated, isFederatedDataOp, isGPUEnabled, isMatrix, isMemEstimated, isOutputEmptyBlocks, isRequiredDecompression, isScalar, isTransposeSafe, isVisited, prefetchActivated, printErrorLocation, refreshColsParameterInformation, refreshColsParameterInformation, refreshMemEstimates, refreshRowsParameterInformation, refreshRowsParameterInformation, refreshSizeInformation, requiresCheckpoint, requiresCompression, requiresLineageCaching, requiresReblock, requiresRecompile, resetExecType, resetRecompilationFlag, resetRecompilationFlag, resetVisitStatus, resetVisitStatus, resetVisitStatus, resetVisitStatusForced, rowsKnown, setBeginColumn, setBeginLine, setBlocksize, setCompressedOutput, setCompressedSize, setDataType, setDim, setDim1, setDim2, setEndColumn, setEndLine, setExecType, setFederatedOutput, setFilename, setForcedExecType, setLops, setMemEstimate, setName, setNnz, setOutputEmptyBlocks, setParseInfo, setRequiresCheckpoint, setRequiresCompression, setRequiresCompression, setRequiresDeCompression, setRequiresLineageCaching, setRequiresReblock, setRequiresRecompile, setText, setUpdateType, setValueType, setVisited, setVisited, someInputFederated, toString, updateLopFedOut, updateLopFedOut

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

MultiThreadedHop

public MultiThreadedHop()

MultiThreadedHop

public MultiThreadedHop(String name,
                        Types.DataType dt,
                        Types.ValueType vt)

Method Detail

setMaxNumThreads

public final void setMaxNumThreads(int k)

getMaxNumThreads

public final int getMaxNumThreads()

isMultiThreadedOpType

public abstract boolean isMultiThreadedOpType()