spark - Mirror of Apache Spark

	Commit message (Expand)	Author	Age	Files	Lines
...
*	Fixed bugs and added testcases for naive reduceByKeyAndWindow.	Tathagata Das	2012-09-06	2	-50/+131
*	Re-implemented ReducedWindowedDSteam to simplify and fix bugs. Added slice op...	Tathagata Das	2012-09-06	4	-123/+242
*	Changed DStream member access permissions from private to protected. Updated...	Tathagata Das	2012-09-04	1	-2/+2
*	Added transformRDD DStream operation and TransformedDStream. Added sbt assemb...	Tathagata Das	2012-09-02	1	-1/+1
*	Added StateDStream, corresponding stateful stream operations, and testcases. ...	Tathagata Das	2012-08-31	1	-22/+68
*	Merge branch 'dev' of github.com/radlab/spark into dev	Tathagata Das	2012-08-28	1	-0/+8
\|\
\| *	Reduce log4j verbosity for streaming	Matei Zaharia	2012-08-24	1	-0/+8
* \|	Added capabllity to take streaming input from network. Renamed SparkStreamCon...	Tathagata Das	2012-08-28	1	-2/+2
\|/
*	Added new Clock interface that is used by RecurringTimer to scheduler events ...	Tathagata Das	2012-08-06	1	-8/+20
*	Renamed RDS to DStream, plus minor style fixes	Matei Zaharia	2012-08-02	1	-10/+10
*	1. Refactored SparkStreamContext, Scheduler, InputRDS, FileInputRDS and a few...	Tathagata Das	2012-08-01	1	-0/+65