aboutsummaryrefslogtreecommitdiff
path: root/external/flume-sink/src/main
Commit message (Expand)AuthorAgeFilesLines
* [MINOR][DOCS] Remove consecutive duplicated words/typo in Spark RepoNiranjan Padmanabhan2017-01-041-1/+1
* [MINOR][SQL] Remove extra anonymous closure within functional transformationshyukjinkwon2016-04-143-14/+14
* [SPARK-14073][STREAMING][TEST-MAVEN] Move flume back to SparkShixiong Zhu2016-03-257-0/+819
* [SPARK-13843][STREAMING] Remove streaming-flume, streaming-mqtt, streaming-ze...Shixiong Zhu2016-03-147-819/+0
* [MINOR][DOCS] Fix more typos in comments/strings.Dongjoon Hyun2016-03-141-1/+1
* [SPARK-12692][BUILD][STREAMING] Scala style: Fix the style violation (Space b...Kousuke Saruta2016-01-111-4/+4
* [SPARK-3873][STREAMING] Import order fixes for streaming.Marcelo Vanzin2015-12-311-1/+1
* [SPARK-8962] Add Scalastyle rule to ban direct use of Class.forName; fix exis...Josh Rosen2015-07-141-0/+2
* [SPARK-8483] [STREAMING] Remove commons-lang3 dependency from Flume Si…Hari Shreedharan2015-06-221-2/+2
* [SPARK-8015] [FLUME] Remove Guava dependency from flume-sink.Marcelo Vanzin2015-06-022-3/+36
* [SPARK-7929] Turn whitespace checker on for more token types.Reynold Xin2015-05-281-1/+1
* [SPARK-7145] [CORE] commons-lang (2.x) classes used instead of commons-lang3 ...Sean Owen2015-04-271-2/+2
* [SPARK-3154][STREAMING] Replace ConcurrentHashMap with mutable.HashMap and re...zsxwing2014-12-081-11/+12
* [SPARK-3686][STREAMING] Wait for sink to commit the channel before check...Hari Shreedharan2014-09-253-1/+35
* [SPARK-3154][STREAMING] Make FlumePollingInputDStream shutdown cleaner.Hari Shreedharan2014-08-272-19/+55
* [SPARK-3054][STREAMING] Add unit tests for Spark Sink.Hari Shreedharan2014-08-201-1/+0
* [HOTFIX][STREAMING] Allow the JVM/Netty to decide which port to bind to in Fl...Hari Shreedharan2014-08-171-0/+8
* [STREAMING] SPARK-1729. Make Flume pull data from source, rather than the cur...Hari Shreedharan2014-07-296-0/+706