aboutsummaryrefslogtreecommitdiff
path: root/external/kafka/src/test/java
Commit message (Expand)AuthorAgeFilesLines
* SPARK-6225 [CORE] [SQL] [STREAMING] Resolve most build warnings, 1.3.0 editionSean Owen2015-03-113-34/+22
* [SPARK-4964] [Streaming] refactor createRDD to take leaders via map instead o...cody koeninger2015-02-111-0/+156
* [SPARK-4964][Streaming][Kafka] More updates to Exactly-once Kafka streamTathagata Das2015-02-092-2/+162
* [SPARK-4062][Streaming]Add ReliableKafkaReceiver in Spark Streaming Kafka con...jerryshao2014-11-141-18/+26
* [SPARK-3615][Streaming]Fix Kafka unit test hard coded Zookeeper port issuejerryshao2014-09-241-1/+1
* [SPARK-1022][Streaming] Add Kafka real unit testjerryshao2014-08-051-19/+106
* [SPARK-1332] Improve Spark Streaming's Network Receiver and InputDStream API ...Tathagata Das2014-04-211-4/+6
* Removed XYZFunctions and added XYZUtils as a common Scala and Java interface ...Tathagata Das2014-01-071-8/+3
* Changed JavaStreamingContextWith*** to ***Function in streaming.api.java.*** ...Tathagata Das2014-01-061-8/+7
* Refactored kafka, flume, zeromq, mqtt as separate external projects, with the...Tathagata Das2013-12-301-0/+51