com
.
ibm
.
sparktc
.
sparkbench
.
workload
exercise
package
exercise
Visibility
Public
All
Type Members
case class
CacheTest
(
input:
Option
[
String
]
,
output:
Option
[
String
]
,
saveMode:
String
=
SaveModes.error
,
sleepMs:
Long
)
extends
Workload
with
Product
with
Serializable
case class
CacheTestResult
(
name:
String
,
timestamp:
Long
,
runTime1:
Long
,
runTime2:
Long
,
runTime3:
Long
)
extends
Product
with
Serializable
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
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
case class
SleepResult
(
name:
String
,
timestamp:
Long
,
total_runtime:
Long
)
extends
Product
with
Serializable
case class
SparkPi
(
input:
Option
[
String
] =
None
,
output:
Option
[
String
] =
None
,
saveMode:
String
=
SaveModes.error
,
slices:
Int
)
extends
Workload
with
Product
with
Serializable
case class
SparkPiResult
(
name:
String
,
timestamp:
Long
,
total_runtime:
Long
,
pi_approximate:
Double
)
extends
Product
with
Serializable
Value Members
object
CacheTest
extends
WorkloadDefaults
with
Serializable
object
PartitionAndSleepWorkload
extends
WorkloadDefaults
with
Serializable
object
Sleep
extends
WorkloadDefaults
with
Serializable
object
SparkPi
extends
WorkloadDefaults
with
Serializable
Ungrouped