Package

com.ibm.sparktc.sparkbench.workload

exercise

Permalink

package exercise

Visibility
  1. Public
  2. All

Type Members

  1. case class CacheTest(input: Option[String], output: Option[String], saveMode: String = SaveModes.error, sleepMs: Long) extends Workload with Product with Serializable

    Permalink
  2. case class CacheTestResult(name: String, timestamp: Long, runTime1: Long, runTime2: Long, runTime3: Long) extends Product with Serializable

    Permalink
  3. case class PartitionAndSleepWorkload(input: Option[String] = None, output: Option[String] = None, saveMode: String = SaveModes.error, partitions: Int, sleepMS: Long) extends Workload with Product with Serializable

    Permalink
  4. case class Sleep(input: Option[String] = None, output: Option[String] = None, saveMode: String = SaveModes.error, sleepMS: Long, distribution: Option[String] = None, distributionMean: Option[Double] = None, distributionStd: Option[Double] = None, distributionMin: Option[Long] = None, distributionMax: Option[Long] = None) extends Workload with Product with Serializable

    Permalink
  5. case class SleepResult(name: String, timestamp: Long, total_runtime: Long) extends Product with Serializable

    Permalink
  6. case class SparkPi(input: Option[String] = None, output: Option[String] = None, saveMode: String = SaveModes.error, slices: Int) extends Workload with Product with Serializable

    Permalink
  7. case class SparkPiResult(name: String, timestamp: Long, total_runtime: Long, pi_approximate: Double) extends Product with Serializable

    Permalink

Value Members

  1. object CacheTest extends WorkloadDefaults with Serializable

    Permalink
  2. object PartitionAndSleepWorkload extends WorkloadDefaults with Serializable

    Permalink
  3. object Sleep extends WorkloadDefaults with Serializable

    Permalink
  4. object SparkPi extends WorkloadDefaults with Serializable

    Permalink

Ungrouped