Fix Accumulators in Java, and add a test for them
Merge pull request #350 from tdas/streaming

Spark Streaming
attempt to sleep for more accurate time period, minor cleanup
add missing return
add unit test
correct test params
add one extra test
add comment
more code cleanup
switch to uppercase constants
Merge pull request #365 from ryanlecompte/rate_limiter_timing_cleanup

Improve sleeping algorithm for rate limiting output streams
Merge pull request #366 from tdas/streaming

Code refactoring
Removed stream id from the constructor of NetworkReceiver to make it easier for PluggableNetworkInputDStream.
Added documentation for PairDStreamFunctions.
Fixed bug
Minor name fix
Merge pull request #370 from tdas/streaming

Added more documentation and minor change in API for NetworkReceiver
A very rough, early cut at some Java functionality for Streaming.
Adding some initial tests to streaming API.
Remving main method from tests