spark - Mirror of Apache Spark

	Commit message (Expand)	Author	Age	Files	Lines
*	Adding a Twitter InputDStream with an example	Patrick Wendell	2012-12-21	2	-0/+96
*	Added kafka JAR	Denny	2012-12-05	1	-0/+0
*	Adjust Kafka code to work with new streaming changes.	Denny	2012-12-05	2	-4/+5
*	Merge branch 'dev' into kafka	Denny	2012-12-05	22	-109/+139
\|\
\| *	Minor mods	Tathagata Das	2012-12-02	1	-1/+1
\| *	Made RDD checkpoint not create a new thread. Fixed bug in detecting when spar...	Tathagata Das	2012-12-02	1	-4/+5
\| *	Minor modifications.	Tathagata Das	2012-12-01	3	-5/+22
\| *	Added ssc.union	Tathagata Das	2012-12-01	2	-1/+6
\| *	Bug fixes	Tathagata Das	2012-11-28	1	-1/+1
\| *	Modified bunch HashMaps in Spark to use TimeStampedHashMap and made various m...	Tathagata Das	2012-11-27	1	-4/+9
\| *	Merged branch mesos/master to branch dev.	Tathagata Das	2012-11-26	1	-1/+1
\| *	Modified StreamingContext API to make constructor accept the batch size (sinc...	Tathagata Das	2012-11-19	16	-98/+92
\| *	Fixed bug in the number of splits in RDD after checkpointing. Modified reduce...	Tathagata Das	2012-11-19	4	-3/+11
* \|	Added Kafka Wordcount producer	Denny	2012-11-19	2	-25/+52
* \|	Comment out code for fault-tolerance.	Denny	2012-11-19	1	-17/+18
* \|	Merge branch 'dev' into kafka	Denny	2012-11-19	4	-3/+173
\|\\|
\| *	Merge branch 'dev' of github.com:radlab/spark into dev	Tathagata Das	2012-11-17	2	-0/+170
\| \|\
\| \| *	Merge pull request #4 from radlab/streaming-example	Patrick Wendell	2012-11-16	2	-0/+170
\| \| \|\
\| \| \| *	A "streaming page view" example.	Patrick Wendell	2012-11-16	2	-0/+170
\| * \| \|	Fixed checkpointing bug in CoGroupedRDD. CoGroupSplits kept around the RDD sp...	Tathagata Das	2012-11-17	2	-3/+3
\| \|/ /
* \| \|	Merge branch 'dev' into kafka	Denny	2012-11-13	9	-123/+155
\|\\| \|
\| * \|	Fixed bug in MappedValuesRDD, and set default graph checkpoint interval to be...	Tathagata Das	2012-11-13	3	-5/+22
\| * \|	Replaced StateRDD in StateDStream with MapPartitionsRDD.	Tathagata Das	2012-11-13	1	-12/+3
\| * \|	Optimized checkpoint writing by reusing FileSystem object. Fixed bug in updat...	Tathagata Das	2012-11-13	7	-106/+128
* \| \|	change import for example function	Denny	2012-11-13	1	-1/+1
* \| \|	Merge branch 'dev' into kafka	Denny	2012-11-12	26	-2055/+331
\|\\| \|
\| * \|	Speeded up CheckpointSuite	Tathagata Das	2012-11-12	1	-12/+14
\| * \|	Changed default level on calling DStream.persist() to be MEMORY_ONLY_SER. Als...	Tathagata Das	2012-11-12	2	-2/+2
\| * \|	Fixed bugs in RawNetworkInputDStream and in its examples. Made the ReducedWin...	Tathagata Das	2012-11-12	11	-376/+167
\| * \|	Merge branch 'dev' of github.com:radlab/spark into dev	tdas	2012-11-11	2	-22/+148
\| \|\ \
\| \| * \|	Fixed bug in FileInputDStream that allowed it to miss new files. Added tests ...	Tathagata Das	2012-11-11	2	-22/+148
\| * \| \|	Removed unnecessary files.	tdas	2012-11-08	10	-1643/+0
\| \|/ /
* \| \|	Updated comment.	Denny	2012-11-11	1	-1/+1
* \| \|	Add comment.	Denny	2012-11-11	1	-0/+2
* \| \|	Kafka Stream comments.	Denny	2012-11-11	5	-53/+99
* \| \|	Merge branch 'dev' of github.com:radlab/spark into kafka	Denny	2012-11-09	8	-50/+263
\|\\| \|
\| * \|	Fixed bug in InputStreamsSuite	tdas	2012-11-08	1	-0/+2
\| * \|	Added FailureTestsuite for testing multiple, repeated master failures.	Tathagata Das	2012-11-06	7	-49/+256
\| * \|	Added a few more comments to the checkpoint-related functions.	Tathagata Das	2012-11-05	1	-0/+8
* \| \|	Kafka Stream.	Denny	2012-11-09	9	-161/+245
* \| \|	Merge branch 'dev' of github.com:radlab/spark into kafka	Denny	2012-11-06	16	-237/+545
\|\\| \|
\| * \|	Made more bug fixes for checkpointing.	Tathagata Das	2012-11-05	6	-66/+97
\| * \|	Fixed major bugs in checkpointing.	Tathagata Das	2012-11-05	8	-85/+213
\| * \|	Made checkpointing of dstream graph to work with checkpointing of RDDs. For s...	Tathagata Das	2012-11-04	15	-188/+337
\| \|/
* /	Working on kafka.	Denny	2012-11-06	3	-0/+159
\|/
*	Fixed serialization bug in countByWindow, added countByKey and countByKeyAndW...	Tathagata Das	2012-11-02	5	-48/+186
*	Added save operations to DStreams.	Tathagata Das	2012-10-27	3	-3/+84
*	Merge branch 'dev' of github.com:radlab/spark into dev	Tathagata Das	2012-10-25	16	-23/+29
\|\
\| *	Merge remote-tracking branch 'public/master' into dev	Matei Zaharia	2012-10-24	16	-23/+29
* \|	Added tests for the file input stream.	Tathagata Das	2012-10-24	2	-8/+64
\|/