aboutsummaryrefslogtreecommitdiff
path: root/external/kafka
Commit message (Expand)AuthorAgeFilesLines
* Revert "[SPARK-14613][ML] Add @Since into the matrix and vector classes in sp...Yin Huai2016-04-281-1/+1
* [SPARK-14613][ML] Add @Since into the matrix and vector classes in spark-mlli...Pravin Gadakh2016-04-281-1/+1
* [SPARK-14868][BUILD] Enable NewLineAtEofChecker in checkstyle and fix lint-ja...Dongjoon Hyun2016-04-241-1/+1
* [SPARK-14134][CORE] Change the package name used for shading classes.Marcelo Vanzin2016-04-061-1/+1
* [MINOR][DOCS] Use multi-line JavaDoc comments in Scala code.Dongjoon Hyun2016-04-021-7/+8
* [SPARK-13928] Move org.apache.spark.Logging into org.apache.spark.internal.Lo...Wenchen Fan2016-03-176-6/+11
* [SPARK-13848][SPARK-5185] Update to Py4J 0.9.2 in order to fix classloading i...Josh Rosen2016-03-141-1/+1
* [MINOR][DOCS] Fix more typos in comments/strings.Dongjoon Hyun2016-03-141-1/+1
* [SPARK-13823][CORE][STREAMING][SQL] Always specify Charset in String <-> byte...Sean Owen2016-03-131-2/+2
* [SPARK-12073][STREAMING] backpressure rate controller consumes events prefere...Jason White2016-03-046-30/+97
* [SPARK-13423][WIP][CORE][SQL][STREAMING] Static analysis fixes for 2.xSean Owen2016-03-031-1/+1
* [SPARK-13186][STREAMING] migrate away from SynchronizedMapHuaxin Gao2016-02-221-6/+7
* [SPARK-13165][STREAMING] Replace deprecated synchronizedBuffer in streamingHolden Karau2016-02-091-22/+21
* [SPARK-10963][STREAMING][KAFKA] make KafkaCluster publiccody koeninger2016-02-071-9/+10
* [SPARK-6363][BUILD] Make Scala 2.11 the default Scala versionJosh Rosen2016-01-301-2/+2
* [SPARK-12692][BUILD][STREAMING] Scala style: Fix the style violation (Space b...Kousuke Saruta2016-01-113-5/+5
* [STREAMING][MINOR] Typo fixesJacek Laskowski2016-01-112-2/+2
* [SPARK-12618][CORE][STREAMING][SQL] Clean up build warnings: 2.0.0 editionSean Owen2016-01-082-9/+6
* [SPARK-3873][TESTS] Import ordering fixes.Marcelo Vanzin2016-01-052-4/+3
* [SPARK-3873][STREAMING] Import order fixes for streaming.Marcelo Vanzin2015-12-316-20/+23
* Bump master version to 2.0.0-SNAPSHOT.Reynold Xin2015-12-191-1/+1
* [SPARK-12103][STREAMING][KAFKA][DOC] document that K means Key and V …cody koeninger2015-12-081-0/+61
* [DOCUMENTATION][KAFKA] fix typo in kafka/OffsetRange.scalamicrowishing2015-12-032-2/+2
* [SPARK-9065][STREAMING][PYSPARK] Add MessageHandler for Kafka Python APIjerryshao2015-11-171-86/+159
* [SPARK-11790][STREAMING][TESTS] Increase the connection timeoutShixiong Zhu2015-11-171-1/+1
* [SPARK-10300] [BUILD] [TESTS] Add support for test tags in run-tests.py.Marcelo Vanzin2015-10-071-8/+2
* Revert "[SPARK-10300] [BUILD] [TESTS] Add support for test tags in run-tests....Marcelo Vanzin2015-09-151-0/+10
* [SPARK-10300] [BUILD] [TESTS] Add support for test tags in run-tests.py.Marcelo Vanzin2015-09-151-10/+0
* Update version to 1.6.0-SNAPSHOT.Reynold Xin2015-09-151-1/+1
* [SPARK-10547] [TEST] Streamline / improve style of Java API testsSean Owen2015-09-123-27/+28
* [SPARK-10227] fatal warnings with sbt on Scala 2.11Luc Bourlier2015-09-092-3/+3
* [SPARK-9613] [CORE] Ban use of JavaConversions and migrate all existing uses ...Sean Owen2015-08-252-18/+21
* [SPARK-9786] [STREAMING] [KAFKA] fix backpressure so it works with defa…cody koeninger2015-08-241-2/+7
* [SPARK-9791] [PACKAGE] Change private class to private class to prevent unnec...Tathagata Das2015-08-244-45/+15
* [SPARK-9780] [STREAMING] [KAFKA] prevent NPE if KafkaRDD instantiation …cody koeninger2015-08-121-1/+5
* [DOCS] [STREAMING] make the existing parameter docs for OffsetRange ac…cody koeninger2015-08-061-4/+4
* [SPARK-9556] [SPARK-9619] [SPARK-9624] [STREAMING] Make BlockGenerator more r...Tathagata Das2015-08-061-1/+1
* [SPARK-8978] [STREAMING] Implements the DirectKafkaRateControllerNilanjan Raychaudhuri2015-08-062-9/+127
* [SPARK-9534] [BUILD] Enable javac lint for scalac parity; fix a lot of build ...Sean Owen2015-08-041-1/+1
* [SPARK-9144] Remove DAGScheduler.runLocallyWithinThread and spark.localExecut...Josh Rosen2015-07-221-2/+1
* [SPARK-7977] [BUILD] Disallowing printlnJonathan Alter2015-07-101-1/+1
* [SPARK-8865] [STREAMING] FIX BUG: check key in kafka paramsguowei22015-07-091-1/+1
* [SPARK-8389] [STREAMING] [PYSPARK] Expose KafkaRDDs offsetRange in Pythonjerryshao2015-07-091-0/+13
* [SPARK-8701] [STREAMING] [WEBUI] Add input metadata in the batch pagezsxwing2015-07-092-5/+20
* [SPARK-8127] [STREAMING] [KAFKA] KafkaRDD optimize count() take() isEmpty()cody koeninger2015-06-197-24/+119
* [SPARK-8390] [STREAMING] [KAFKA] fix docs related to HasOffsetRangescody koeninger2015-06-192-5/+22
* [SPARK-8389] [STREAMING] [KAFKA] Example of getting offset ranges out o…cody koeninger2015-06-191-2/+13
* [SPARK-8404] [STREAMING] [TESTS] Use thread-safe collections to make the test...zsxwing2015-06-174-19/+14
* [SPARK-2808] [STREAMING] [KAFKA] cleanup tests fromcody koeninger2015-06-073-22/+2
* [SPARK-7801] [BUILD] Updating versions to SPARK 1.5.0Patrick Wendell2015-06-031-1/+1
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-02 11:50:01 +0000