diff options
| author | cody koeninger <cody@koeninger.org> | 2015-02-11 00:13:27 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-02-11 00:13:27 -0800 |
| commit | 658687b25491047f30ee8558733d11e5a0572070 (patch) | |
| tree | 9f4d67993bcdf9b331a65a917d79b487bbf4cf7b /docs/building-spark.md | |
| parent | c2131c0cdc57a4871ea23cd71e27e066d3c9a42c (diff) | |
| download | spark-658687b25491047f30ee8558733d11e5a0572070.tar.gz spark-658687b25491047f30ee8558733d11e5a0572070.tar.bz2 spark-658687b25491047f30ee8558733d11e5a0572070.zip | |
[SPARK-4964] [Streaming] refactor createRDD to take leaders via map instead of array
Author: cody koeninger <cody@koeninger.org>
Closes #4511 from koeninger/kafkaRdd-leader-to-broker and squashes the following commits:
f7151d4 [cody koeninger] [SPARK-4964] test refactoring
6f8680b [cody koeninger] [SPARK-4964] add test of the scala api for KafkaUtils.createRDD
f81e016 [cody koeninger] [SPARK-4964] leave KafkaStreamSuite host and port as private
5173f3f [cody koeninger] [SPARK-4964] test the Java variations of createRDD
e9cece4 [cody koeninger] [SPARK-4964] pass leaders as a map to ensure 1 leader per TopicPartition
Diffstat (limited to 'docs/building-spark.md')
0 files changed, 0 insertions, 0 deletions