Add hBase example
Add hBase dependency to examples POM
implement FIFO and fair scheduler for spark local mode
1. Add unit test for local scheduler
2. Move localTaskSetManager to a new file
enhance pipe to support what we can do in hadoop streaming
Adding example to make Spark RDD from Cassandra
Removing infix call
Adding deps to examples/pom.xml
Fixing exclusion in examples deps in SparkBuild.scala
add ut for pipe enhancement
A better way to read column value if you are sure the column exists in every row.
Example to write the output to cassandra
In the current code, when both partitions happen to have zero-length, the return mean will be NaN.
Consequently, the result of mean after reducing over all partitions will also be NaN,
which is not correct if there are partitions with non-zero length. This patch fixes this issue.
update according to comments
change code style and debug info
add a new top K method to RDD using a bounded priority queue
Fixing the style as per feedback
use Iterator.single(elem) instead of Iterator(elem) for improved performance based on scaladocs
drop unneeded ClassManifest implicit
Update LocalSchedulerSuite to avoid using sleep for task launch
use delegation for BoundedPriorityQueue, add Java API