spark - Mirror of Apache Spark

	Commit message (Expand)	Author	Age	Files	Lines
*	Added back the initial spark job before starting streaming receivers	Tathagata Das	2013-02-24	1	-1/+1
*	Updated streaming programming guide with Java API info, and comments from Pat...	Tathagata Das	2013-02-23	2	-3/+2
*	Fixed differences in APIs of StreamingContext and JavaStreamingContext. Chang...	Tathagata Das	2013-02-23	4	-25/+231
*	Merge branch 'mesos-streaming' into streaming	Tathagata Das	2013-02-22	2	-2/+56
\|\
\| *	Merge pull request #479 from ScrapCodes/zeromq-streaming	Tathagata Das	2013-02-22	2	-2/+56
\| \|\
\| \| *	fixes corresponding to review feedback at pull request #479	Prashant Sharma	2013-02-20	1	-1/+1
\| \| *	example for demonstrating ZeroMQ stream	Prashant Sharma	2013-02-19	1	-8/+7
\| \| *	ZeroMQ stream as receiver	Prashant Sharma	2013-02-19	2	-0/+55
* \| \|	Fixed condition in InputDStream isTimeValid.	Tathagata Das	2013-02-21	1	-1/+1
\|/ /
* \|	Merge branch 'mesos-streaming' into streaming	Tathagata Das	2013-02-20	6	-49/+102
\|\ \
\| * \|	Small changes that were missing in merge	Patrick Wendell	2013-02-19	2	-0/+2
\| * \|	Use RDD type for `slice` operator in Java.	Patrick Wendell	2013-02-19	1	-2/+2
\| * \|	Use RDD type for `transform` operator in Java.	Patrick Wendell	2013-02-19	2	-7/+122
\| * \|	Use RDD type for `foreach` operator in Java.	Patrick Wendell	2013-02-19	6	-11/+21
\| \|/
* \|	Merge branch 'mesos-master' into streaming	Tathagata Das	2013-02-20	9	-24/+234
\|\ \ \| \|/ \|/\|
\| *	Rename "jobs" to "applications" in the standalone cluster	Matei Zaharia	2013-02-17	3	-9/+9
\| *	Make CoGroupedRDDs explicitly have the same key type.	Stephen Haberman	2013-02-16	3	-3/+3
\| *	STREAMING-50: Support transform workaround in JavaPairDStream	Patrick Wendell	2013-02-12	2	-2/+77
\| *	Using tuple swap()	Patrick Wendell	2013-02-11	1	-2/+2
\| *	small fix	Patrick Wendell	2013-02-11	1	-2/+2
\| *	Fix for MapPartitions	Patrick Wendell	2013-02-11	2	-17/+54
\| *	Fix for flatmap	Patrick Wendell	2013-02-11	2	-2/+44
\| *	Indentation fix	Patrick Wendell	2013-02-11	1	-10/+10
\| *	Initial cut at replacing K, V in Java files	Patrick Wendell	2013-02-11	2	-2/+58
* \|	Merge branch 'streaming' into ScrapCodes-streaming-actor	Tathagata Das	2013-02-19	36	-1056/+1855
\|\ \
\| * \|	Changed networkStream to socketStream and pluggableNetworkStream to become ne...	Tathagata Das	2013-02-18	4	-21/+22
\| * \|	Merge branch 'streaming' into ScrapCode-streaming	Tathagata Das	2013-02-18	35	-1027/+1844
\| \|\ \
\| \| * \|	Added checkpointing and fault-tolerance semantics to the programming guide. F...	Tathagata Das	2013-02-18	6	-6/+11
\| \| * \|	Many changes to ensure better 2nd recovery if 2nd failure happens while	Tathagata Das	2013-02-17	18	-97/+208
\| \| * \|	Made MasterFailureTest more robust.	Tathagata Das	2013-02-15	1	-4/+22
\| \| * \|	Moved Java streaming examples to examples/src/main/java/spark/streaming/... a...	Tathagata Das	2013-02-14	1	-1/+1
\| \| * \|	Added TwitterInputDStream from example to StreamingContext. Renamed example T...	Tathagata Das	2013-02-14	2	-17/+105
\| \| * \|	Removed countByKeyAndWindow on paired DStreams, and added countByValueAndWind...	Tathagata Das	2013-02-14	8	-183/+226
\| \| * \|	Changes functions comments to make them more consistent.	Tathagata Das	2013-02-13	2	-45/+45
\| \| * \|	Added filter functionality to reduceByKeyAndWindow with inverse. Consolidated...	Tathagata Das	2013-02-13	7	-81/+102
\| \| * \|	Changed scheduler and file input stream to fix bugs in the driver fault toler...	Tathagata Das	2013-02-13	18	-452/+693
\| \| * \|	Fixed bugs in FileInputDStream and Scheduler that occasionally failed to repr...	Tathagata Das	2013-02-10	6	-91/+221
\| \| * \|	Added an initial spark job to ensure worker nodes are initialized.	Tathagata Das	2013-02-09	2	-2/+7
\| \| * \|	Merge branch 'mesos-master' into streaming	Tathagata Das	2013-02-07	12	-15/+24
\| \| \|\\|
\| \| \| *	Streaming constructor which takes JavaSparkContext	Patrick Wendell	2013-02-05	1	-0/+8
\| \| \| *	Merge pull request #415 from stephenh/driver	Matei Zaharia	2013-01-29	7	-8/+8
\| \| \| \|\
\| \| \| \| *	Replace old 'master' term with 'driver'.	Stephen Haberman	2013-01-25	7	-8/+8
\| \| \| * \|	Fix code that depended on metadata cleaner interval being in minutes	Matei Zaharia	2013-01-28	2	-5/+5
\| \| \| \|/
\| \| \| *	Refactor daemon thread pool creation.	Josh Rosen	2013-01-21	1	-2/+3
\| \| \| *	Move JavaAPISuite into spark.streaming.	Stephen Haberman	2013-01-21	2	-0/+0
\| \| * \|	Updated JavaStreamingContext with updated kafkaStream API.	Tathagata Das	2013-02-07	1	-17/+9
\| \| * \|	Merge branch 'mesos-streaming' into streaming	Tathagata Das	2013-02-07	5	-88/+91
\| \| \|\ \
\| \| \| * \	Merge pull request #372 from Reinvigorate/sm-kafka	Tathagata Das	2013-02-07	2	-91/+13
\| \| \| \|\ \
\| \| \| \| * \|	kafkaStream API cleanup. A quorum of zookeepers can now be specified	seanm	2013-01-18	2	-15/+10
\| \| \| \| * \|	further KafkaInputDStream cleanup (removing unused and commented out code rel...	seanm	2013-01-18	1	-69/+3