spark - Mirror of Apache Spark

	Commit message (Expand)	Author	Age	Files	Lines
...
* \| \| \|	commit opt for grep scalibility test.	haoyuan	2012-09-07	3	-31/+45
\| \|/ / \|/\| \|
* \| \|	Less warmup in word count	root	2012-09-06	1	-1/+1
* \| \|	Merge branch 'dev' of github.com:radlab/spark into dev	root	2012-09-05	1	-1/+1
\|\ \ \
\| * \| \|	Merge branch 'dev' of github.com:radlab/spark into dev	root	2012-09-05	6	-56/+201
\| \|\\| \|
\| * \| \|	Some changes to make important log output visible even if we set the logging ...	root	2012-09-05	1	-1/+1
* \| \| \|	Tuning Akka for more connections	root	2012-09-05	1	-5/+5
\| \|/ / \|/\| \|
* \| \|	Merge branch 'dev' of github.com:radlab/spark into dev	Tathagata Das	2012-09-04	4	-2/+229
\|\ \ \
\| * \| \|	fix the compile error in TopKWordCountRaw.scala	haoyuan	2012-09-04	1	-6/+6
\| * \| \|	add TopKWordCountRaw.scala	haoyuan	2012-09-04	1	-0/+86
\| \|/ /
\| * \|	Merge branch 'dev' of github.com:radlab/spark into dev	root	2012-09-04	7	-97/+345
\| \|\\|
\| * \|	Various test programs	root	2012-09-04	3	-2/+143
* \| \|	Changed DStream member access permissions from private to protected. Updated...	Tathagata Das	2012-09-04	4	-35/+80
* \| \|	Updated the return types of PairDStreamFunctions to return DStreams instead o...	Tathagata Das	2012-09-04	1	-21/+35
\| \|/ \|/\|
* \|	Merge branch 'dev' of github.com:radlab/spark into dev	Tathagata Das	2012-09-02	15	-70/+368
\|\\|
\| *	tweaks	root	2012-09-01	1	-1/+1
\| *	More raw network receiver programs	root	2012-09-01	3	-1/+76
\| *	Make batch size configurable in RawCount	root	2012-09-01	1	-6/+6
\| *	Further fixes to raw text sender, plus an app that uses it	root	2012-09-01	7	-5/+56
\| *	Bug fixes to RateLimitedOutputStream	Matei Zaharia	2012-09-01	1	-1/+3
\| *	First work towards a RawInputDStream and a sender program for it.	Matei Zaharia	2012-09-01	8	-50/+218
\| *	Bug fix	Matei Zaharia	2012-08-31	1	-1/+1
\| *	Bug fix	Matei Zaharia	2012-08-31	1	-1/+1
\| *	Better output messages for streaming job duration	Matei Zaharia	2012-08-31	2	-5/+3
\| *	WordCount tweaks	root	2012-08-31	1	-7/+10
\| *	Make checkpoint interval configurable in WordCount2	root	2012-08-31	1	-7/+8
* \|	Added transformRDD DStream operation and TransformedDStream. Added sbt assemb...	Tathagata Das	2012-09-02	3	-19/+46
* \|	Added StateDStream, corresponding stateful stream operations, and testcases. ...	Tathagata Das	2012-08-31	7	-82/+303
\|/
*	Compile fixes	root	2012-08-29	2	-4/+4
*	Merge branch 'dev' of github.com/radlab/spark into dev	Tathagata Das	2012-08-28	8	-55/+143
\|\
\| *	Made WordCount2 even more configurable	root	2012-08-27	1	-5/+7
\| *	Merge branch 'dev' of github.com:radlab/spark into dev	root	2012-08-27	1	-14/+12
\| \|\
\| \| *	Code style	Matei Zaharia	2012-08-26	1	-14/+12
\| * \|	Tweaks to WordCount2	root	2012-08-27	1	-6/+13
\| \|/
\| *	Made Time and Interval immutable	Matei Zaharia	2012-08-26	5	-51/+13
\| *	Merge branch 'dev' of github.com:radlab/spark into dev	Matei Zaharia	2012-08-26	3	-4/+106
\| \|\
\| \| *	Added sliding word count, and some fixes to reduce window DStream	root	2012-08-26	3	-4/+106
\| * \|	Add equals and hashCode to Time	Matei Zaharia	2012-08-26	1	-0/+8
\| \|/
\| *	Make Time serializable	Matei Zaharia	2012-08-26	1	-1/+1
\| *	Reduce log4j verbosity for streaming	Matei Zaharia	2012-08-24	1	-0/+8
\| *	Fix WordCount job name	Matei Zaharia	2012-08-24	1	-1/+1
* \|	Added capabllity to take streaming input from network. Renamed SparkStreamCon...	Tathagata Das	2012-08-28	19	-142/+502
\|/
*	Added new Clock interface that is used by RecurringTimer to scheduler events ...	Tathagata Das	2012-08-06	6	-30/+130
*	Renamed RDS to DStream, plus minor style fixes	Matei Zaharia	2012-08-02	16	-185/+183
*	Added an RDS that repeatedly returns the same input	Matei Zaharia	2012-08-02	1	-0/+18
*	Added a WordCount for external data and fixed bugs in file streams	Matei Zaharia	2012-08-02	3	-7/+33
*	Moved streaming files not immediately necessary to spark.streaming.util.	Tathagata Das	2012-08-01	9	-19/+14
*	1. Refactored SparkStreamContext, Scheduler, InputRDS, FileInputRDS and a few...	Tathagata Das	2012-08-01	46	-2432/+796
*	Restructured file locations to separate examples and other programs from core...	Tathagata Das	2012-07-30	28	-159/+27
*	Renamed stream package to streaming	Matei Zaharia	2012-07-29	46	-50/+50
*	Added the Spark Streaing code, ported to Akka 2	Matei Zaharia	2012-07-28	46	-0/+5081