Track and report write throughput for shuffle tasks.
Adding option to force sync to the filesystem
Trying new approach with writes
Perf benchmark
Minor cleanup
Making the timing block more narrow for the sync
Upgrade Kafka 0.7.2 to Kafka 0.8.0-beta1 for Spark Streaming
mqttinputdstream for mqttstreaming adapter
added mqtt adapter
added mqtt adapter library dependencies
added mqtt adapter wordcount example
add maven dependencies for mqtt
add maven dependencies for mqtt
remove unused dependency
remove unused dependency
modify code, use Spark Logging Class
Added a number of very fast, memory-efficient data structures: BitSet, OpenHashSet, OpenHashMap, PrimitiveKeyOpenHashMap.
Update MQTTInputDStream.scala
Update MQTTWordCount.scala
Initial commit of adding histogram functionality to the DoubleRDDFunctions.