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.
Merge remote-tracking branch 'public/dev' into dev
Fix WordCount job name
Reduce log4j verbosity for streaming
Fix sendMessageReliablySync
Make Time serializable
Less debug info
Added sliding word count, and some fixes to reduce window DStream
Add equals and hashCode to Time