spark - Mirror of Apache Spark

	Commit message (Expand)	Author	Age	Files	Lines
*	Minor fixes.	Tathagata Das	2012-10-24	4	-27/+27
*	Added tests for testing network input stream.	Tathagata Das	2012-10-24	5	-23/+134
*	Renamed the streaming testsuites.	Tathagata Das	2012-10-23	4	-6/+8
*	Renamed APIs to create queueStream and fileStream.	Tathagata Das	2012-10-23	5	-10/+10
*	Updated StateDStream api to use Options instead of nulls.	Tathagata Das	2012-10-23	3	-18/+18
*	Renamed the network input streams.	Tathagata Das	2012-10-23	7	-35/+40
*	Modified API of NetworkInputDStreams and got ObjectInputDStream and RawInputD...	Tathagata Das	2012-10-23	8	-382/+360
*	Renamed examples	Tathagata Das	2012-10-22	2	-7/+7
*	Added MapValueDStream, FlatMappedValuesDStream and CoGroupedDStream, and ther...	Tathagata Das	2012-10-21	9	-35/+293
*	Fixed some bugs in tests for forgetting RDDs, and made sure that use of manua...	Tathagata Das	2012-10-21	10	-89/+100
*	Added functionality to forget RDDs from DStreams.	Tathagata Das	2012-10-19	11	-79/+224
*	Minor modifications.	Tathagata Das	2012-10-15	3	-13/+14
*	Refactored DStreamSuiteBase to create CheckpointSuite- testsuite for testing ...	Tathagata Das	2012-10-14	12	-135/+290
*	Fixed bugs in the streaming testsuites.	Tathagata Das	2012-10-13	2	-7/+18
*	Implemented checkpointing of StreamingContext and DStream graph.	Tathagata Das	2012-10-13	14	-165/+536
*	Merge branch 'dev' of github.com:radlab/spark into dev	Tathagata Das	2012-09-17	6	-35/+52
\|\
\| *	Minor tweaks	Tathagata Das	2012-09-14	2	-22/+24
\| *	Made NewHadoopRDD broadcast its job configuration (same as HadoopRDD).	Tathagata Das	2012-09-10	1	-4/+6
\| *	Merge branch 'dev' of github.com:radlab/spark into dev	Tathagata Das	2012-09-07	30	-435/+930
\| \|\
\| \| *	add warmup code for TopKWordCountRaw.scala	haoyuan	2012-09-06	1	-5/+14
\| * \|	Fixed bugs in streaming Scheduler and optimized QueueInputDStream.	Tathagata Das	2012-09-07	4	-5/+9
* \| \|	Allowed StreamingContext to be created from existing SparkContext	Tathagata Das	2012-09-17	1	-8/+5
\| \|/ \|/\|
* \|	Merge branch 'dev' of github.com:radlab/spark into dev	haoyuan	2012-09-07	9	-313/+424
\|\ \
\| * \|	Fixed bugs and added testcases for naive reduceByKeyAndWindow.	Tathagata Das	2012-09-06	5	-87/+140
\| * \|	Merge branch 'dev' of github.com:radlab/spark into dev	Tathagata Das	2012-09-06	11	-35/+105
\| \|\ \
\| * \| \|	Re-implemented ReducedWindowedDSteam to simplify and fix bugs. Added slice op...	Tathagata Das	2012-09-06	7	-276/+334
* \| \| \|	commit opt for grep scalibility test.	haoyuan	2012-09-07	4	-32/+51
\| \|/ / \|/\| \|
* \| \|	Less warmup in word count	root	2012-09-06	1	-1/+1
* \| \|	Bug fix	root	2012-09-06	1	-1/+1
* \| \|	Tuning Akka more	root	2012-09-06	1	-2/+2
* \| \|	Serialize map output locations more efficiently, and only once, in MapOutputT...	root	2012-09-05	1	-8/+80
* \| \|	User Spark's closure serializer for the ShuffleMapTask cache	root	2012-09-05	2	-5/+5
* \| \|	Merge branch 'dev' of github.com:radlab/spark into dev	root	2012-09-05	1	-1/+2
\|\ \ \
\| * \| \|	Serialize BlockRDD more efficiently	root	2012-09-05	1	-1/+2
* \| \| \|	Further tuning for network performance	root	2012-09-05	2	-14/+3
* \| \| \|	Merge branch 'dev' of github.com:radlab/spark into dev	root	2012-09-05	4	-4/+11
\|\\| \| \|
\| * \| \|	Allow serializing HttpBroadcast through Kryo	root	2012-09-05	1	-0/+2
\| * \| \|	Broadcast the JobConf in HadoopRDD to reduce task sizes	root	2012-09-05	2	-2/+7
\| * \| \|	Merge branch 'dev' of github.com:radlab/spark into dev	root	2012-09-05	7	-57/+202
\| \|\\| \|
\| * \| \|	Some changes to make important log output visible even if we set the logging ...	root	2012-09-05	2	-2/+2
* \| \| \|	Tuning Akka for more connections	root	2012-09-05	2	-5/+6
\| \|/ / \|/\| \|
* \| \|	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	10	-102/+365
\| \|\\|
\| * \|	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	5	-36/+81
* \| \|	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	23	-126/+483
\|\\|
\| *	tweaks	root	2012-09-01	2	-1/+2