Uses of Class
org.apache.sysds.resource.cost.VarStats
-
Packages that use VarStats Package Description org.apache.sysds.resource.cost -
-
Uses of VarStats in org.apache.sysds.resource.cost
Methods in org.apache.sysds.resource.cost that return VarStats Modifier and Type Method Description VarStats
CostEstimator. getStats(String statsName)
Intended to be called only when it is certain that the corresponding variable is not a scalar and its statistics are in_stats
already.VarStats
CostEstimator. getStatsWithDefaultScalar(String statsName)
Intended to be called when the corresponding variable could be scalar.Methods in org.apache.sysds.resource.cost with parameters of type VarStats Modifier and Type Method Description static void
CPCostUtils. assignOutputMemoryStats(CPInstruction inst, VarStats output, VarStats... inputs)
static void
SparkCostUtils. assignOutputRDDStats(SPInstruction inst, VarStats output, VarStats... inputs)
static double
SparkCostUtils. getAggUnaryInstTime(UnarySPInstruction inst, VarStats input, VarStats output, IOCostUtils.IOMetrics executorMetrics)
static double
SparkCostUtils. getAppendInstTime(AppendSPInstruction inst, VarStats input1, VarStats input2, VarStats output, IOCostUtils.IOMetrics driverMetrics, IOCostUtils.IOMetrics executorMetrics)
static double
CPCostUtils. getBinaryInstTime(BinaryCPInstruction inst, VarStats input1, VarStats input2, VarStats weights, VarStats output, IOCostUtils.IOMetrics metrics)
static double
SparkCostUtils. getBinaryInstTime(SPInstruction inst, VarStats input1, VarStats input2, VarStats output, IOCostUtils.IOMetrics driverMetrics, IOCostUtils.IOMetrics executorMetrics)
static double
CPCostUtils. getBuiltinNaryInstTime(BuiltinNaryCPInstruction inst, VarStats[] inputs, VarStats output, IOCostUtils.IOMetrics metrics)
static double
SparkCostUtils. getCastInstTime(CastSPInstruction inst, VarStats input, VarStats output, IOCostUtils.IOMetrics executorMetrics)
static double
SparkCostUtils. getCentralMomentInstTime(CentralMomentSPInstruction inst, VarStats input, VarStats weights, VarStats output, IOCostUtils.IOMetrics executorMetrics)
static double
CPCostUtils. getComputationInstTime(ComputationCPInstruction inst, VarStats input1, VarStats input2, VarStats input3, VarStats input4, VarStats output, IOCostUtils.IOMetrics metrics)
static double
CPCostUtils. getCPUTime(long nflop, IOCostUtils.IOMetrics driverMetrics, VarStats output, VarStats... inputs)
static double
SparkCostUtils. getCtableInstTime(CtableSPInstruction tableInst, VarStats input1, VarStats input2, VarStats input3, VarStats output, IOCostUtils.IOMetrics executorMetrics)
static double
CPCostUtils. getDataGenCPInstTime(UnaryCPInstruction inst, VarStats output, IOCostUtils.IOMetrics metrics)
static double
IOCostUtils. getFileSystemReadTime(VarStats stats, IOCostUtils.IOMetrics metrics)
Estimates the read time for a file on HDFS or S3 by the Control Programstatic double
IOCostUtils. getFileSystemWriteTime(VarStats stats, IOCostUtils.IOMetrics metrics)
Estimates the time for writing a file to HDFS or S3.static double
IOCostUtils. getHadoopReadTime(VarStats stats, IOCostUtils.IOMetrics metrics)
Estimates the read time for a file on HDFS or S3 by Spark cluster.static double
IOCostUtils. getHadoopWriteTime(VarStats stats, IOCostUtils.IOMetrics metrics)
Estimates the write time for a file on HDFS or S3 by Spark cluster.static double
SparkCostUtils. getIndexingInstTime(IndexingSPInstruction inst, VarStats input1, VarStats input2, VarStats output, IOCostUtils.IOMetrics driverMetrics, IOCostUtils.IOMetrics executorMetrics)
static long
CPCostUtils. getInstNFLOP(CPInstruction.CPType instructionType, String opcode, VarStats output, VarStats... inputs)
static double
SparkCostUtils. getMatMulChainInstTime(MapmmChainSPInstruction inst, VarStats input1, VarStats input2, VarStats input3, VarStats output, IOCostUtils.IOMetrics driverMetrics, IOCostUtils.IOMetrics executorMetrics)
static double
SparkCostUtils. getMatMulInstTime(BinarySPInstruction inst, VarStats input1, VarStats input2, VarStats output, IOCostUtils.IOMetrics driverMetrics, IOCostUtils.IOMetrics executorMetrics)
static double
IOCostUtils. getMemReadTime(VarStats stats, IOCostUtils.IOMetrics metrics)
Estimate time to scan object in memory in CP.static double
IOCostUtils. getMemWriteTime(VarStats stats, IOCostUtils.IOMetrics metrics)
Estimate time to write object to memory in CP.static double
CPCostUtils. getMultiReturnBuiltinInstTime(MultiReturnBuiltinCPInstruction inst, VarStats input, VarStats[] outputs, IOCostUtils.IOMetrics metrics)
static double
CPCostUtils. getParameterizedBuiltinInstTime(ParameterizedBuiltinCPInstruction inst, VarStats input, VarStats output, IOCostUtils.IOMetrics metrics)
static double
SparkCostUtils. getParameterizedBuiltinInstTime(ParameterizedBuiltinSPInstruction paramInst, VarStats input1, VarStats input2, VarStats output, IOCostUtils.IOMetrics driverMetrics, IOCostUtils.IOMetrics executorMetrics)
static double
SparkCostUtils. getQSortInstTime(QuantileSortSPInstruction inst, VarStats input, VarStats weights, VarStats output, IOCostUtils.IOMetrics executorMetrics)
static double
SparkCostUtils. getQuaternaryInstTime(QuaternarySPInstruction quatInst, VarStats input1, VarStats input2, VarStats input3, VarStats output, IOCostUtils.IOMetrics driverMetrics, IOCostUtils.IOMetrics executorMetrics)
static double
SparkCostUtils. getRandInstTime(String opcode, int randType, VarStats output, IOCostUtils.IOMetrics executorMetrics)
static double
SparkCostUtils. getReblockInstTime(String opcode, VarStats input, VarStats output, IOCostUtils.IOMetrics executorMetrics)
static double
SparkCostUtils. getReorgInstTime(UnarySPInstruction inst, VarStats input, VarStats output, IOCostUtils.IOMetrics executorMetrics)
static double
SparkCostUtils. getTernaryInstTime(TernarySPInstruction tInst, VarStats input1, VarStats input2, VarStats input3, VarStats output, IOCostUtils.IOMetrics executorMetrics)
double
CostEstimator. getTimeEstimateSparkJob(VarStats varToCollect)
static double
SparkCostUtils. getTSMMInstTime(UnarySPInstruction inst, VarStats input, VarStats output, IOCostUtils.IOMetrics driverMetrics, IOCostUtils.IOMetrics executorMetrics)
static double
CPCostUtils. getUnaryInstTime(UnaryCPInstruction inst, VarStats input, VarStats weights, VarStats output, IOCostUtils.IOMetrics metrics)
static double
SparkCostUtils. getUnaryInstTime(String opcode, VarStats input, VarStats output, IOCostUtils.IOMetrics executorMetrics)
static double
CPCostUtils. getVariableInstTime(VariableCPInstruction inst, VarStats input, VarStats output, IOCostUtils.IOMetrics metrics)
static void
CPCostUtils. inferStats(CPInstruction.CPType instType, String opcode, VarStats output, VarStats... inputs)
Method parameters in org.apache.sysds.resource.cost with type arguments of type VarStats Modifier and Type Method Description void
CostEstimator. putStats(HashMap<String,VarStats> inputStats)
Meant to be used for testing purposesConstructors in org.apache.sysds.resource.cost with parameters of type VarStats Constructor Description RDDStats(VarStats sourceStats)
Initiates RDD statistics object bound to an existingVarStats
object.
-