-
- Downloads
[SPARK-12177][STREAMING][KAFKA] limit api surface area
## What changes were proposed in this pull request? This is an alternative to the refactoring proposed by https://github.com/apache/spark/pull/13996 ## How was this patch tested? unit tests also tested under scala 2.10 via mvn -Dscala-2.10 Author: cody koeninger <cody@koeninger.org> Closes #13998 from koeninger/kafka-0-10-refactor.
Showing
- external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/ConsumerStrategy.scala 90 additions, 97 deletions...rg/apache/spark/streaming/kafka010/ConsumerStrategy.scala
- external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/DirectKafkaInputDStream.scala 1 addition, 1 deletion...he/spark/streaming/kafka010/DirectKafkaInputDStream.scala
- external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaRDD.scala 2 additions, 2 deletions.../scala/org/apache/spark/streaming/kafka010/KafkaRDD.scala
- external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaTestUtils.scala 3 additions, 2 deletions.../org/apache/spark/streaming/kafka010/KafkaTestUtils.scala
- external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaUtils.scala 20 additions, 16 deletions...cala/org/apache/spark/streaming/kafka010/KafkaUtils.scala
- external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/LocationStrategy.scala 41 additions, 33 deletions...rg/apache/spark/streaming/kafka010/LocationStrategy.scala
- external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/package.scala 1 addition, 1 deletion...n/scala/org/apache/spark/streaming/kafka010/package.scala
- external/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaConsumerStrategySuite.java 17 additions, 15 deletions...e/spark/streaming/kafka010/JavaConsumerStrategySuite.java
- external/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaDirectKafkaStreamSuite.java 4 additions, 4 deletions.../spark/streaming/kafka010/JavaDirectKafkaStreamSuite.java
- external/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaKafkaRDDSuite.java 7 additions, 2 deletions...rg/apache/spark/streaming/kafka010/JavaKafkaRDDSuite.java
- external/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaLocationStrategySuite.java 10 additions, 9 deletions...e/spark/streaming/kafka010/JavaLocationStrategySuite.java
- external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/DirectKafkaStreamSuite.scala 25 additions, 10 deletions...che/spark/streaming/kafka010/DirectKafkaStreamSuite.scala
- external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/KafkaRDDSuite.scala 1 addition, 1 deletion...a/org/apache/spark/streaming/kafka010/KafkaRDDSuite.scala
Loading
Please register or sign in to comment