spark - Mirror of Apache Spark

	Commit message (Expand)	Author	Age	Files	Lines
...
*	Removed stream id from the constructor of NetworkReceiver to make it easier f...	Tathagata Das	2013-01-13	6	-30/+68
*	Changed variable name form *Time to *Duration to keep things consistent.	Tathagata Das	2013-01-09	26	-186/+176
*	Split Time to Time (absolute instant of time) and Duration (duration of time).	Tathagata Das	2013-01-09	25	-152/+174
*	Moved Twitter example to the where the other examples are.	Tathagata Das	2013-01-07	2	-104/+0
*	Merge branch 'streaming-merge' into dev-merge	Tathagata Das	2013-01-07	2	-0/+104
\|\
\| *	Merge pull request #8 from radlab/twitter-example	Patrick Wendell	2012-12-29	2	-0/+104
\| \|\
\| \| *	Minor changes after review and general cleanup.	Patrick Wendell	2012-12-21	2	-11/+19
\| \| *	Adding a Twitter InputDStream with an example	Patrick Wendell	2012-12-21	2	-0/+96
* \| \|	Merge branch 'dev' into dev-merge	Tathagata Das	2013-01-07	16	-639/+37
\|\ \ \
\| * \| \|	Changed locations for unit test logs.	Tathagata Das	2013-01-07	1	-2/+2
\| * \| \|	Fixed bug	Tathagata Das	2013-01-07	1	-1/+1
\| * \| \|	Renamed examples and added documentation.	Tathagata Das	2013-01-07	3	-21/+35
\| * \| \|	Moved Spark Streaming examples to examples sub-project.	Tathagata Das	2013-01-06	12	-616/+0
* \| \| \|	BufferingBlockCreator -> NetworkReceiver.BlockGenerator	Patrick Wendell	2013-01-02	5	-94/+89
* \| \| \|	Merge branch 'dev-merge' into datahandler-fix	Patrick Wendell	2013-01-02	46	-507/+721
\|\\| \| \|
\| * \| \|	Updated Streaming Programming Guide.	Tathagata Das	2013-01-01	1	-0/+1
\| * \| \|	More classes made private[streaming] to hide from scala docs.	Tathagata Das	2012-12-30	17	-52/+135
\| * \| \|	Refactored a whole lot to push all DStreams into the spark.streaming.dstream ...	Tathagata Das	2012-12-30	40	-333/+401
\| * \| \|	Improved jekyll and scala docs. Made many classes and method private to remov...	Tathagata Das	2012-12-29	16	-139/+201
* \| \| \|	Several code-quality improvements to DataHandler.	Patrick Wendell	2013-01-02	5	-88/+84
\|/ / /
* \| \|	Modifications to make sure LocalScheduler terminate cleanly without errors wh...	Tathagata Das	2012-12-27	1	-5/+8
* \| \|	Merge branch 'dev' of github.com:radlab/spark into dev-checkpoint	Tathagata Das	2012-12-20	14	-110/+683
\|\\| \|
\| * \|	Changes in response to TD's review.	Patrick Wendell	2012-12-07	6	-15/+29
\| * \|	Adding Flume InputDStream	Patrick Wendell	2012-12-07	8	-6/+246
\| \|/
\| *	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
\| \|\
\| * \|	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' into kafka	Denny	2012-11-13	9	-123/+155
\| \|\ \ \
\| * \| \| \|	change import for example function	Denny	2012-11-13	1	-1/+1
\| * \| \| \|	Merge branch 'dev' into kafka	Denny	2012-11-12	26	-2055/+331
\| \|\ \ \ \
\| * \| \| \| \|	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
\| \|\ \ \ \ \
\| * \| \| \| \| \|	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
\| \|\ \ \ \ \ \
\| * \| \| \| \| \| \|	Working on kafka.	Denny	2012-11-06	3	-0/+159
* \| \| \| \| \| \| \|	Made checkpoint data in RDDs optional to further reduce serialized size.	Tathagata Das	2012-12-11	1	-3/+1
* \| \| \| \| \| \| \|	Refactored RDD checkpointing to minimize extra fields in RDD class.	Tathagata Das	2012-12-04	1	-3/+4
\| \|_\|_\|_\|_\|_\|/ \|/\| \| \| \| \| \|
* \| \| \| \| \| \|	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