spark - Mirror of Apache Spark

	Commit message (Expand)	Author	Age	Files	Lines
*	[SPARK-7056] [STREAMING] Make the Write Ahead Log pluggable	Tathagata Das	2015-04-29	1	-1/+2
*	[SPARK-5946] [STREAMING] Add Python API for direct Kafka stream	jerryshao	2015-04-27	1	-1/+91
*	[SPARK-7052][Core] Add ThreadUtils and move thread methods from Utils to Thre...	zsxwing	2015-04-22	2	-4/+5
*	[Streaming][minor] Remove additional quote and unneeded imports	jerryshao	2015-04-16	1	-2/+1
*	[SPARK-6431][Streaming][Kafka] Error message for partition metadata requ...	cody koeninger	2015-04-12	1	-3/+11
*	[SPARK-6211][Streaming] Add Python Kafka API unit test	jerryshao	2015-04-09	1	-0/+261
*	SPARK-6569 [STREAMING] Down-grade same-offset message in Kafka streaming to INFO	Sean Owen	2015-04-06	1	-1/+1
*	[SPARK-6428] Turn on explicit type checking for public methods.	Reynold Xin	2015-04-03	2	-4/+5
*	[SPARK-6279][Streaming]In KafkaRDD.scala, Miss expressions flag "s" at loggin...	zzcclp	2015-03-11	1	-1/+1
*	[Streaming][Minor] Remove useless type signature of Java Kafka direct stream API	Saisai Shao	2015-02-27	1	-1/+1
*	[SPARK-6027][SPARK-5546] Fixed --jar and --packages not working for KafkaUtil...	Tathagata Das	2015-02-26	1	-1/+28
*	[SPARK-4964] [Streaming] refactor createRDD to take leaders via map instead o...	cody koeninger	2015-02-11	2	-37/+64
*	[SPARK-4964][Streaming][Kafka] More updates to Exactly-once Kafka stream	Tathagata Das	2015-02-09	7	-122/+348
*	[SPARK-4707][STREAMING] Reliable Kafka Receiver can lose data if the blo...	Hari Shreedharan	2015-02-04	1	-4/+23
*	[SPARK-4964] [Streaming] Exactly-once semantics for Kafka	cody koeninger	2015-02-04	7	-1/+1107
*	fixed spelling errors in documentation	Peter Klipfel	2014-12-14	1	-3/+3
*	[SPARK-4062][Streaming]Add ReliableKafkaReceiver in Spark Streaming Kafka con...	jerryshao	2014-11-14	3	-15/+304
*	[SPARK-2492][Streaming] kafkaReceiver minor changes to align with Kafka 0.8	jerryshao	2014-11-11	2	-36/+5
*	[SPARK-2103][Streaming] Change to ClassTag for KafkaInputDStream and fix refl...	jerryshao	2014-08-01	2	-18/+12
*	SPARK-2034. KafkaInputDStream doesn't close resources and may prevent JVM shu...	Sean Owen	2014-06-22	1	-22/+33
*	Package docs	Prashant Sharma	2014-05-14	2	-0/+44
*	[SPARK-1332] Improve Spark Streaming's Network Receiver and InputDStream API ...	Tathagata Das	2014-04-21	2	-19/+14
*	Merge pull request #557 from ScrapCodes/style. Closes #557.	Patrick Wendell	2014-02-09	2	-6/+11
*	Removed StreamingContext.registerInputStream and registerOutputStream - they ...	Tathagata Das	2014-01-13	1	-3/+1
*	Fixed import formatting.	Tathagata Das	2014-01-12	1	-1/+1
*	Fixed persistence logic of WindowedDStream, and fixed default persistence lev...	Tathagata Das	2014-01-12	1	-1/+2
*	Moved DStream, DStreamCheckpointData and PairDStream from org.apache.spark.st...	Tathagata Das	2014-01-12	1	-1/+2
*	Removed XYZFunctions and added XYZUtils as a common Scala and Java interface ...	Tathagata Das	2014-01-07	4	-203/+153
*	Changed JavaStreamingContextWith* to Function in streaming.api.java.** ...	Tathagata Das	2014-01-06	1	-6/+6
*	Removed extra empty lines.	Tathagata Das	2013-12-31	1	-1/+0
*	Refactored kafka, flume, zeromq, mqtt as separate external projects, with the...	Tathagata Das	2013-12-30	4	-0/+358