-
- Downloads
[SPARK-9791] [PACKAGE] Change private class to private class to prevent...
[SPARK-9791] [PACKAGE] Change private class to private class to prevent unnecessary classes from showing up in the docs In addition, some random cleanup of import ordering Author: Tathagata Das <tathagata.das1565@gmail.com> Closes #8387 from tdas/SPARK-9791 and squashes the following commits: 67f3ee9 [Tathagata Das] Change private class to private[package] class to prevent them from showing up in the docs
Showing
- external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumeUtils.scala 1 addition, 1 deletion...n/scala/org/apache/spark/streaming/flume/FlumeUtils.scala
- external/kafka/src/main/scala/org/apache/spark/streaming/kafka/Broker.scala 2 additions, 4 deletions.../main/scala/org/apache/spark/streaming/kafka/Broker.scala
- external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala 4 additions, 6 deletions...ala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala
- external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala 9 additions, 27 deletions...n/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala
- external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala 0 additions, 8 deletions.../scala/org/apache/spark/streaming/kafka/OffsetRange.scala
- external/mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTUtils.scala 3 additions, 3 deletions...ain/scala/org/apache/spark/streaming/mqtt/MQTTUtils.scala
- external/mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTTestUtils.scala 1 addition, 1 deletion...scala/org/apache/spark/streaming/mqtt/MQTTTestUtils.scala
- extras/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisTestUtils.scala 1 addition, 1 deletion...org/apache/spark/streaming/kinesis/KinesisTestUtils.scala
- streaming/src/main/java/org/apache/spark/streaming/util/WriteAheadLog.java 2 additions, 0 deletions...n/java/org/apache/spark/streaming/util/WriteAheadLog.java
- streaming/src/main/java/org/apache/spark/streaming/util/WriteAheadLogRecordHandle.java 2 additions, 0 deletions...pache/spark/streaming/util/WriteAheadLogRecordHandle.java
- streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceivedBlockHandler.scala 1 addition, 1 deletion...pache/spark/streaming/receiver/ReceivedBlockHandler.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala 1 addition, 1 deletion...rg/apache/spark/streaming/scheduler/ReceiverTracker.scala
- streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala 1 addition, 1 deletion.../main/scala/org/apache/spark/streaming/ui/BatchPage.scala
Loading
Please register or sign in to comment