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
Fixing the style as per feedback
Update LocalSchedulerSuite to avoid using sleep for task launch
Add zeroLengthPartitions() test to make sure, e.g., StatCounter.scala can handle empty partitions without incorrectly returning NaN
Move zero-length partition testing from JavaAPISuite.java to PartitioningSuite.scala
Import just scala.math.abs rather than scala.math._
update according to comments