aboutsummaryrefslogtreecommitdiff
path: root/external/mqtt/src
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-10227] fatal warnings with sbt on Scala 2.11Luc Bourlier2015-09-091-1/+1
* [SPARK-9791] [PACKAGE] Change private class to private class to prevent unnec...Tathagata Das2015-08-242-4/+4
* [SPARK-5155] [PYSPARK] [STREAMING] Mqtt streaming support in PythonPrabeesh K2015-08-104-103/+186
* [SPARK-7558] Demarcate tests in unit-tests.logAndrew Or2015-05-291-3/+3
* [SPARK-7929] Turn whitespace checker on for more token types.Reynold Xin2015-05-281-13/+1
* [SPARK-7501] [STREAMING] DAG visualization: show DStream operationsAndrew Or2015-05-181-1/+2
* [SPARK-6758]block the right jetty package in logWangTaoTheTonic2015-04-091-1/+1
* [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-253-20/+21
* SPARK-4682 [CORE] Consolidate various 'Clock' classesSean Owen2015-02-191-1/+1
* 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-022-15/+46
* [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-4159 [CORE] Maven build doesn't run JUnit test suitesSean Owen2015-01-061-3/+2
* [SPARK-4631] unit test for MQTTbilna2015-01-041-15/+95
* [SPARK-1010] Clean up uses of System.setProperty in unit testsJosh Rosen2014-12-301-2/+6
* SPARK-3962 Marked scope as provided for external projects.Prashant Sharma2014-11-192-2/+50
* [SPARK-3748] Log thread name in unit test logsReynold Xin2014-10-011-1/+1
* Package docsPrashant Sharma2014-05-142-0/+44
* SPARK-1798. Tests should clean up temp filesSean Owen2014-05-121-1/+1
* SPARK-1586 Windows build fixesMridul Muralidharan2014-04-241-1/+1
* [SPARK-1332] Improve Spark Streaming's Network Receiver and InputDStream API ...Tathagata Das2014-04-214-32/+33
* Remove Unnecessary Whitespace'sSandeep2014-04-101-8/+8
* Changed SparkConf to not be serializable. And also fixed unit-test log paths ...Tathagata Das2014-01-142-1/+2
* Removed StreamingContext.registerInputStream and registerOutputStream - they ...Tathagata Das2014-01-131-3/+1
* Fixed import formatting.Tathagata Das2014-01-121-1/+1
* Fixed persistence logic of WindowedDStream, and fixed default persistence lev...Tathagata Das2014-01-121-0/+1
* Moved DStream, DStreamCheckpointData and PairDStream from org.apache.spark.st...Tathagata Das2014-01-121-1/+2
* Fixed bugs.Tathagata Das2014-01-121-1/+1
* Change clientId to random clientId Prabeesh K2014-01-101-1/+1
* Removed XYZFunctions and added XYZUtils as a common Scala and Java interface ...Tathagata Das2014-01-075-92/+39
* Changed JavaStreamingContextWith*** to ***Function in streaming.api.java.*** ...Tathagata Das2014-01-065-11/+9
* Refactored kafka, flume, zeromq, mqtt as separate external projects, with the...Tathagata Das2013-12-307-0/+342