spark - Mirror of Apache Spark

	Commit message (Expand)	Author	Age	Files	Lines
...
* \|	Minor formatting fixes	Tathagata Das	2013-06-24	3	-19/+34
* \|	Merge pull request #572 from Reinvigorate/sm-block-interval	Tathagata Das	2013-06-24	1	-1/+1
\|\ \
\| * \|	adding spark.streaming.blockInterval property	seanm	2013-04-16	1	-1/+1
* \| \|	Merge pull request #571 from Reinvigorate/sm-kafka-serializers	Tathagata Das	2013-06-24	5	-27/+67
\|\ \ \
\| * \| \|	fixing kafkaStream Java API and adding test	seanm	2013-05-10	2	-3/+13
\| * \| \|	fixing indentation	seanm	2013-05-10	1	-1/+1
\| * \| \|	adding kafkaStream API tests	seanm	2013-05-10	2	-2/+13
\| * \| \|	Surfacing decoders on KafkaInputDStream	seanm	2013-04-16	4	-24/+43
\| \|/ /
* \| \|	count() now uses a transform instead of ConstantInputDStream	seanm	2013-05-10	1	-4/+1
* \| \|	fixing Spark Streaming count() so that 0 will be emitted when there is nothin...	seanm	2013-04-15	2	-3/+6
\|/ /
* \|	fixing autooffset.reset behavior when set to 'largest'	seanm	2013-03-26	1	-4/+6
* \|	keeping JavaStreamingContext in sync with StreamingContext + adding comments ...	seanm	2013-03-15	2	-6/+7
* \|	removing dependency on ZookeeperConsumerConnector + purging last relic of kaf...	seanm	2013-03-15	3	-59/+6
* \|	fixing memory leak in kafka MessageHandler	seanm	2013-03-14	1	-4/+1
* \|	KafkaInputDStream improvements. Allows more Kafka configurability	seanm	2013-03-14	2	-19/+51
\|/
*	Fixed class paths and dependencies based on Matei's comments.	Tathagata Das	2013-02-24	1	-11/+0
*	Added back the initial spark job before starting streaming receivers	Tathagata Das	2013-02-24	1	-1/+1
*	Fixed missing dependencies in streaming/pom.xml	Tathagata Das	2013-02-24	1	-4/+14
*	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	3	-2/+66
\|\
\| *	Merge pull request #480 from MLnick/streaming-eg-algebird	Tathagata Das	2013-02-22	1	-0/+10
\| \|\
\| \| *	Merge remote-tracking branch 'upstream/streaming' into streaming-eg-algebird	Nick Pentreath	2013-02-21	11	-43/+306
\| \| \|\
\| \| * \|	Dependencies and refactoring for streaming HLL example, and using context.twi...	Nick Pentreath	2013-02-19	1	-0/+10
\| * \| \|	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	46	-1056/+2026
\|\ \
\| * \|	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	45	-1027/+2015
\| \|\ \
\| \| * \|	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