1205 commits

Author	SHA1	Message	Date
Tathagata Das	ed897ac5e1	Moved streaming files not immediately necessary to spark.streaming.util.	2012-08-01 22:28:54 -07:00
Tathagata Das	3be54c2a8a	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.	2012-08-01 22:09:27 -07:00
Tathagata Das	5a26ca4a80	Restructured file locations to separate examples and other programs from core programs.	2012-07-30 13:29:13 -07:00
Matei Zaharia	fcee4153b9	Renamed stream package to streaming	2012-07-29 13:35:22 -07:00
Matei Zaharia	47b7ebad12	Added the Spark Streaing code, ported to Akka 2	2012-07-28 20:03:26 -07:00