cogroup | 1 sec | Passed |
count | 2.1 sec | Passed |
countByValue | 2.2 sec | Passed |
filter | 1.1 sec | Passed |
flatMap | 1 sec | Passed |
flatMapValues | 1.1 sec | Passed |
fullOuterJoin | 2.8 sec | Passed |
glom | 1.8 sec | Passed |
groupByKey | 2.7 sec | Passed |
join | 0.93 sec | Passed |
leftOuterJoin | 1 sec | Passed |
map | 1.3 sec | Passed |
mapPartitions | 2.3 sec | Passed |
mapValues | 0.94 sec | Passed |
rdd cleanup - input blocks and persisted RDDs | 5.4 sec | Passed |
rdd cleanup - map and window | 2.1 sec | Passed |
rdd cleanup - updateStateByKey | 4 sec | Passed |
reduce | 1.3 sec | Passed |
reduceByKey | 1.2 sec | Passed |
repartition (fewer partitions) | 1.7 sec | Passed |
repartition (more partitions) | 2.2 sec | Passed |
rightOuterJoin | 1.3 sec | Passed |
slice | 3.1 sec | Passed |
slice - has not been initialized | 0.69 sec | Passed |
transform | 0.76 sec | Passed |
transform | 0.73 sec | Passed |
transform with NULL | 0.56 sec | Passed |
transform with input stream return None | 0.47 sec | Passed |
transform with input stream return None | 0.46 sec | Passed |
transformWith | 0.95 sec | Passed |
transformWith with input stream return None | 0.67 sec | Passed |
union | 0.7 sec | Passed |
union | 1 sec | Passed |
union with input stream return None | 0.7 sec | Passed |
updateStateByKey | 1.4 sec | Passed |
updateStateByKey - object lifecycle | 2 sec | Passed |
updateStateByKey - simple with initial value RDD | 1.1 sec | Passed |
updateStateByKey - testing time stamps as input | 1.2 sec | Passed |
updateStateByKey - with initial value RDD | 1.7 sec | Passed |