spark - Mirror of Apache Spark

	Commit message (Expand)	Author	Age	Files	Lines
*	Merge pull request #476 from tdas/streaming	Tathagata Das	2013-02-19	52	-862/+2142
\|\
\| *	Added comment to the KafkaWordCount, given by Sean McNamara.	Tathagata Das	2013-02-19	1	-0/+12
\| *	Merge branch 'mesos-streaming' into streaming	Tathagata Das	2013-02-19	0	-0/+0
\| \|\ \| \|/ \|/\|
* \|	Merge pull request #455 from tdas/streaming	Tathagata Das	2013-02-07	183	-2473/+4256
\|\ \
\| \| *	Merge branch 'streaming' into ScrapCodes-streaming-actor	Tathagata Das	2013-02-19	209	-3356/+5876
\| \| \|\
\| \| \| *	Changed networkStream to socketStream and pluggableNetworkStream to become ne...	Tathagata Das	2013-02-18	9	-35/+36
\| \| \| *	Merge branch 'streaming' into ScrapCode-streaming	Tathagata Das	2013-02-18	242	-3438/+9569
\| \| \| \|\
\| \| \| \| *	Added checkpointing and fault-tolerance semantics to the programming guide. F...	Tathagata Das	2013-02-18	8	-59/+206
\| \| \| \| *	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	4	-1/+1
\| \| \| \| *	Added TwitterInputDStream from example to StreamingContext. Renamed example T...	Tathagata Das	2013-02-14	4	-45/+53
\| \| \| \| *	Removed countByKeyAndWindow on paired DStreams, and added countByValueAndWind...	Tathagata Das	2013-02-14	9	-189/+231
\| \| \| \| *	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
\| \| \| \| *	Fixed bug in CheckpointRDD to prevent exception when the original RDD had zer...	Tathagata Das	2013-02-10	2	-2/+12
\| \| \| \| *	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	177	-2220/+3876
\| \|\ \ \
\| \| * \ \	Merge pull request #450 from stephenh/inlinemergepair	Matei Zaharia	2013-02-05	1	-6/+4
\| \| \|\ \ \
\| \| \| * \| \|	Inline mergePair to look more like the narrow dep branch.	Stephen Haberman	2013-02-05	1	-6/+4
\| \| * \| \| \|	Merge pull request #451 from stephenh/fixdeathpactexception	Matei Zaharia	2013-02-05	2	-19/+13
\| \| \|\ \ \ \
\| \| \| * \ \ \	Merge branch 'master' into fixdeathpactexception	Stephen Haberman	2013-02-05	30	-258/+991
\| \| \| \|\ \ \ \ \| \| \| \|/ / / / \| \| \|/\| \| \| \|
\| \| * \| \| \| \|	Merge pull request #449 from stephenh/longerdriversuite	Matei Zaharia	2013-02-05	1	-1/+2
\| \| \|\ \ \ \ \
\| \| \| * \| \| \| \|	Increase DriverSuite timeout.	Stephen Haberman	2013-02-05	1	-1/+2
\| \| \| \| \|/ / / \| \| \| \|/\| \| \|
\| \| * \| \| \| \|	Merge pull request #447 from pwendell/streaming-constructor	Matei Zaharia	2013-02-05	1	-0/+8
\| \| \|\ \ \ \ \
\| \| \| * \| \| \| \|	Streaming constructor which takes JavaSparkContext	Patrick Wendell	2013-02-05	1	-0/+8
\| \| \|/ / / / /
\| \| * \| \| \| \|	Small fix to test for distinct	Matei Zaharia	2013-02-04	1	-1/+1
\| \| * \| \| \| \|	Fix failing test	Matei Zaharia	2013-02-04	1	-2/+1
\| \| * \| \| \| \|	Merge pull request #445 from JoshRosen/pyspark_fixes	Matei Zaharia	2013-02-03	5	-22/+19
\| \| \|\ \ \ \ \
\| \| \| * \| \| \| \|	Remove unnecessary doctest __main__ methods.	Josh Rosen	2013-02-03	2	-18/+0
\| \| \| * \| \| \| \|	Fetch fewer objects in PySpark's take() method.	Josh Rosen	2013-02-03	2	-2/+13
\| \| \| * \| \| \| \|	Fix reporting of PySpark doctest failures.	Josh Rosen	2013-02-03	2	-2/+6
\| \| \| \|/ / / /
\| \| * \| \| \| \|	Merge pull request #379 from stephenh/sparkmem	Matei Zaharia	2013-02-02	6	-35/+17
\| \| \|\ \ \ \ \
\| \| \| * \| \| \| \|	Fix dangling old variable names.	Stephen Haberman	2013-02-02	1	-2/+2
\| \| \| * \| \| \| \|	Move executorMemory up into SchedulerBackend.	Stephen Haberman	2013-02-02	4	-29/+12
\| \| \| * \| \| \| \|	Merge branch 'master' into sparkmem	Stephen Haberman	2013-02-02	254	-2124/+13947
\| \| \| \|\\| \| \| \|
\| \| \| * \| \| \| \|	Fix SPARK_MEM in ExecutorRunner.	Stephen Haberman	2013-01-22	1	-1/+1
\| \| \| * \| \| \| \|	Restore SPARK_MEM in executorEnvs.	Stephen Haberman	2013-01-22	1	-2/+3
\| \| \| * \| \| \| \|	Add spark.executor.memory to differentiate executor memory from spark-shell m...	Stephen Haberman	2013-01-15	3	-10/+8
\| \| * \| \| \| \| \|	Merge pull request #422 from squito/blockmanager_info	Matei Zaharia	2013-02-02	6	-38/+59
\| \| \|\ \ \ \ \ \
\| \| \| * \| \| \| \| \|	remove unneeded (and unused) filter on block info	Imran Rashid	2013-02-01	1	-2/+0
\| \| \| * \| \| \| \| \|	track total partitions, in addition to cached partitions; use scala string fo...	Imran Rashid	2013-02-01	3	-9/+13
\| \| \| * \| \| \| \| \|	fixup merge (master -> driver renaming)	Imran Rashid	2013-02-01	1	-1/+1
\| \| \| * \| \| \| \| \|	Merge branch 'master' into blockmanager_info	Imran Rashid	2013-01-30	43	-246/+291
\| \| \| \|\ \ \ \ \ \
\| \| \| * \| \| \| \| \| \|	rename Slaves --> Executor	Imran Rashid	2013-01-30	2	-5/+5
\| \| \| * \| \| \| \| \| \|	Merge branch 'master' into blockmanager_info	Imran Rashid	2013-01-29	23	-192/+207
\| \| \| \|\ \ \ \ \ \ \
\| \| \| * \| \| \| \| \| \| \|	better formatting for RDDInfo	Imran Rashid	2013-01-28	1	-3/+9
\| \| \| * \| \| \| \| \| \| \|	expose RDD & storage info directly via SparkContext	Imran Rashid	2013-01-28	4	-28/+41