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	2	-19/+198
*	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	4	-45/+54
\|\ \
\| * \|	Small changes that were missing in merge	Patrick Wendell	2013-02-19	1	-0/+1
\| * \|	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	1	-5/+35
\| * \|	Use RDD type for `foreach` operator in Java.	Patrick Wendell	2013-02-19	4	-9/+17
\| \|/
* \|	Merge branch 'mesos-master' into streaming	Tathagata Das	2013-02-20	8	-21/+51
\|\ \ \| \|/ \|/\|
\| *	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	1	-2/+32
\| *	Fix for MapPartitions	Patrick Wendell	2013-02-11	1	-2/+2
\| *	Fix for flatmap	Patrick Wendell	2013-02-11	1	-2/+2
\| *	Initial cut at replacing K, V in Java files	Patrick Wendell	2013-02-11	1	-2/+2
* \|	Merge branch 'streaming' into ScrapCodes-streaming-actor	Tathagata Das	2013-02-19	27	-616/+1412
\|\ \
\| * \|	Changed networkStream to socketStream and pluggableNetworkStream to become ne...	Tathagata Das	2013-02-18	2	-17/+19
\| * \|	Merge branch 'streaming' into ScrapCode-streaming	Tathagata Das	2013-02-18	26	-593/+1392
\| \|\ \
\| \| * \|	Added checkpointing and fault-tolerance semantics to the programming guide. F...	Tathagata Das	2013-02-18	5	-5/+10
\| \| * \|	Many changes to ensure better 2nd recovery if 2nd failure happens while	Tathagata Das	2013-02-17	11	-68/+141
\| \| * \|	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	5	-128/+173
\| \| * \|	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	5	-64/+68
\| \| * \|	Changed scheduler and file input stream to fix bugs in the driver fault toler...	Tathagata Das	2013-02-13	10	-104/+557
\| \| * \|	Fixed bugs in FileInputDStream and Scheduler that occasionally failed to repr...	Tathagata Das	2013-02-10	5	-10/+21
\| \| * \|	Added an initial spark job to ensure worker nodes are initialized.	Tathagata Das	2013-02-09	1	-1/+6
\| \| * \|	Merge branch 'mesos-master' into streaming	Tathagata Das	2013-02-07	5	-9/+18
\| \| \|\\|
\| \| \| *	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	1	-2/+2
\| \| \| \|\
\| \| \| \| *	Replace old 'master' term with 'driver'.	Stephen Haberman	2013-01-25	1	-2/+2
\| \| \| * \|	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
\| \| * \|	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	3	-88/+41
\| \| \|\ \
\| \| \| * \	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
\| \| \| \| * \|	Removing offset management code that is non-existent in kafka 0.7.0+	seanm	2013-01-14	1	-7/+0
\| \| \| * \| \|	Merge pull request #373 from Reinvigorate/sm-updateStateByKey	Tathagata Das	2013-02-07	2	-6/+28
\| \| \| \|\ \ \ \| \| \| \| \|_\|/ \| \| \| \|/\| \|
\| \| \| \| * \|	Splitting StreamingContext.queueStream into two methods	seanm	2013-01-20	1	-4/+18
\| \| \| \| * \|	Merge branch 'streaming' into sm-updateStateByKey	seanm	2013-01-15	2	-5/+5
\| \| \| \| \|\ \