aboutsummaryrefslogtreecommitdiff
path: root/external/mqtt/src/test/scala/org
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-13583][CORE][STREAMING] Remove unused imports and add checkstyle ruleDongjoon Hyun2016-03-031-1/+1
* [SPARK-3873][TESTS] Import ordering fixes.Marcelo Vanzin2016-01-051-1/+1
* [SPARK-9791] [PACKAGE] Change private class to private class to prevent unnec...Tathagata Das2015-08-241-1/+1
* [SPARK-5155] [PYSPARK] [STREAMING] Mqtt streaming support in PythonPrabeesh K2015-08-102-103/+126
* [SPARK-7558] Demarcate tests in unit-tests.logAndrew Or2015-05-291-3/+3
* [SPARK-6765] Fix test code style for streaming.Reynold Xin2015-04-081-1/+2
* [SPARK-5559] [Streaming] [Test] Remove oppotunity we met flakiness when runni...Kousuke Saruta2015-03-241-1/+3
* [SPARK-5666][streaming][MQTT streaming] some trivial fixesprabs2015-02-251-6/+6
* SPARK-5728 [STREAMING] MQTTStreamSuite leaves behind ActiveMQ database filesSean Owen2015-02-111-0/+1
* [SPARK-4631][streaming][FIX] Wait for a receiver to start before publishing t...Iulian Dragos2015-02-021-3/+32
* [SPARK-5006][Deploy]spark.port.maxRetries doesn't workWangTaoTheTonic2015-01-131-1/+2
* [Minor]Resolve sbt warnings during build (MQTTStreamSuite.scala).GuoQiang Li2015-01-101-0/+1
* [Minor] Fix import order and other coding stylebilna2015-01-091-6/+11
* [SPARK-4631] unit test for MQTTbilna2015-01-041-15/+95
* SPARK-3962 Marked scope as provided for external projects.Prashant Sharma2014-11-191-2/+10
* [SPARK-1332] Improve Spark Streaming's Network Receiver and InputDStream API ...Tathagata Das2014-04-211-2/+4
* Changed SparkConf to not be serializable. And also fixed unit-test log paths ...Tathagata Das2014-01-141-0/+1
* Fixed bugs.Tathagata Das2014-01-121-1/+1
* Removed XYZFunctions and added XYZUtils as a common Scala and Java interface ...Tathagata Das2014-01-071-2/+2
* Refactored kafka, flume, zeromq, mqtt as separate external projects, with the...Tathagata Das2013-12-301-0/+36