Added the Spark Streaing code, ported to Akka 2
Merge remote-tracking branch 'public/dev' into dev
Renamed stream package to streaming
Restructured file locations to separate examples and other programs from core programs.
Merge remote-tracking branch 'public/dev' into dev
1. Refactored SparkStreamContext, Scheduler, InputRDS, FileInputRDS and a few other files.
2. Modified Time class to represent milliseconds (long) directly, instead of LongTime.
3. Added new files QueueInputRDS, RecurringTimer, etc.
4. Added RDDSuite as the skeleton for testcases.
5. Added two examples in spark.streaming.examples.
6. Removed all past examples and a few unnecessary files. Moved a number of files to spark.streaming.util.
Merge branch 'dev' of github.com:radlab/spark into dev
Moved streaming files not immediately necessary to spark.streaming.util.
Added a WordCount for external data and fixed bugs in file streams
Added an RDS that repeatedly returns the same input
Renamed RDS to DStream, plus minor style fixes
Added new Clock interface that is used by RecurringTimer to scheduler events on system time or manually-configured time.
make accumulator.localValue public, add tests
add accumulators for mutable collections, with correct typing!
Add Python API.
Bundle cloudpickle with pyspark.
change tests to show utility of localValue
Use only cPickle for serialization in Python API.

Objects serialized with JSON can be compared for equality, but JSON can be slow
to serialize and only supports a limited range of data types.
Merge pull request #173 from squito/accum_localValue

make accumulator.localValue public, add tests
Use numpy in Python k-means example.