Commit message (Expand) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | [SPARK-18212][SS][KAFKA] increase executor poll timeout | cody koeninger | 2016-11-03 | 1 | -1/+4 |
* | [SPARK-17813][SQL][KAFKA] Maximum data per trigger | cody koeninger | 2016-10-27 | 2 | -27/+151 |
* | [SPARK-17812][SQL][KAFKA] Assign and specific startingOffsets for structured ... | cody koeninger | 2016-10-21 | 7 | -45/+369 |
* | [SPARK-17999][KAFKA][SQL] Add getPreferredLocations for KafkaSourceRDD | jerryshao | 2016-10-20 | 1 | -0/+5 |
* | [SPARK-17731][SQL][STREAMING] Metrics for structured streaming | Tathagata Das | 2016-10-13 | 1 | -0/+27 |
* | [SPARK-17834][SQL] Fetch the earliest offsets manually in KafkaSource instead... | Shixiong Zhu | 2016-10-13 | 2 | -26/+48 |
* | [SPARK-17346][SQL][TESTS] Fix the flaky topic deletion in KafkaSourceStressSuite | Shixiong Zhu | 2016-10-11 | 1 | -8/+1 |
* | [SPARK-17346][SQL][TEST-MAVEN] Generate the sql test jar to fix the maven build | Shixiong Zhu | 2016-10-05 | 2 | -0/+15 |
* | [SPARK-17346][SQL] Add Kafka source for Structured Streaming | Shixiong Zhu | 2016-10-05 | 12 | -0/+1969 |