aboutsummaryrefslogtreecommitdiff
path: root/external/kafka-0-10-sql/src/main
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-20156][CORE][SQL][STREAMING][MLLIB] Java String toLowerCase "Turkish l...Sean Owen2017-04-101-10/+12
* [SPARK-19721][SS] Good error message for version mismatch in log filesLiwei Lin2017-03-161-7/+7
* [SPARK-19853][SS] uppercase kafka topics fail when startingOffsets are Specif...uncleGen2017-03-121-34/+35
* [SPARK-19886] Fix reportDataLoss if statement in SS KafkaSourceBurak Yavuz2017-03-091-13/+20
* [SPARK-19719][SS] Kafka writer for both structured streaming and batch queiresTyson Condie2017-03-064-5/+341
* [SPARK-19517][SS] KafkaSource fails to initialize partition offsetsRoberto Agostino Vitillo2017-02-171-7/+25
* [SPARK-19550][BUILD][CORE][WIP] Remove Java 7 supportSean Owen2017-02-161-2/+1
* [SPARK-19564][SPARK-19559][SS][KAFKA] KafkaOffsetReader's consumers should no...Liwei Lin2017-02-121-4/+7
* [SPARK-18682][SS] Batch Source for KafkaTyson Condie2017-02-079-429/+924
* [SPARK-19227][SPARK-19251] remove unused imports and outdated commentsuncleGen2017-01-181-1/+1
* [MINOR][DOCS] Remove consecutive duplicated words/typo in Spark RepoNiranjan Padmanabhan2017-01-041-1/+1
* [SPARK-18588][SS][KAFKA] Create a new KafkaConsumer when error happens to fix...Shixiong Zhu2016-12-212-30/+49
* [SPARK-18588][TESTS] Fix flaky test: KafkaSourceStressForDontFailOnDataLossSuiteShixiong Zhu2016-12-072-8/+33
* [SPARK-18671][SS][TEST] Added tests to ensure stability of that all Structure...Tathagata Das2016-12-061-1/+8
* [SPARK-18530][SS][KAFKA] Change Kafka timestamp column type to TimestampTypeShixiong Zhu2016-11-221-3/+13
* [SPARK-18373][SPARK-18529][SS][KAFKA] Make failOnDataLoss=false work with Spa...Shixiong Zhu2016-11-223-48/+253
* [SPARK-18445][BUILD][DOCS] Fix the markdown for `Note:`/`NOTE:`/`Note that`/`...hyukjinkwon2016-11-191-1/+1
* [SPARK-17829][SQL] Stable format for offset logTyson Condie2016-11-093-7/+28
* [SPARK-18212][SS][KAFKA] increase executor poll timeoutcody koeninger2016-11-031-1/+4
* [SPARK-17813][SQL][KAFKA] Maximum data per triggercody koeninger2016-10-271-25/+82
* [SPARK-17812][SQL][KAFKA] Assign and specific startingOffsets for structured ...cody koeninger2016-10-214-33/+208
* [SPARK-17999][KAFKA][SQL] Add getPreferredLocations for KafkaSourceRDDjerryshao2016-10-201-0/+5
* [SPARK-17834][SQL] Fetch the earliest offsets manually in KafkaSource instead...Shixiong Zhu2016-10-132-26/+48
* [SPARK-17346][SQL] Add Kafka source for Structured StreamingShixiong Zhu2016-10-057-0/+1057