diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2015-08-24 12:40:09 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-08-24 12:40:09 -0700 |
| commit | 7478c8b66d6a2b1179f20c38b49e27e37b0caec3 (patch) | |
| tree | 252ac13596be6d9d4be7fedb63cb08d25b063f6e /external/mqtt/src/main | |
| parent | 4e0395ddb764d092b5b38447af49e196e590e0f0 (diff) | |
| download | spark-7478c8b66d6a2b1179f20c38b49e27e37b0caec3.tar.gz spark-7478c8b66d6a2b1179f20c38b49e27e37b0caec3.tar.bz2 spark-7478c8b66d6a2b1179f20c38b49e27e37b0caec3.zip | |
[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
Diffstat (limited to 'external/mqtt/src/main')
| -rw-r--r-- | external/mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTUtils.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/external/mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTUtils.scala b/external/mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTUtils.scala index 38a1114863..7b8d56d6fa 100644 --- a/external/mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTUtils.scala +++ b/external/mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTUtils.scala @@ -21,8 +21,8 @@ import scala.reflect.ClassTag import org.apache.spark.storage.StorageLevel import org.apache.spark.streaming.StreamingContext -import org.apache.spark.streaming.api.java.{JavaReceiverInputDStream, JavaStreamingContext, JavaDStream} -import org.apache.spark.streaming.dstream.{ReceiverInputDStream, DStream} +import org.apache.spark.streaming.api.java.{JavaDStream, JavaReceiverInputDStream, JavaStreamingContext} +import org.apache.spark.streaming.dstream.ReceiverInputDStream object MQTTUtils { /** @@ -79,7 +79,7 @@ object MQTTUtils { * This is a helper class that wraps the methods in MQTTUtils into more Python-friendly class and * function so that it can be easily instantiated and called from Python's MQTTUtils. */ -private class MQTTUtilsPythonHelper { +private[mqtt] class MQTTUtilsPythonHelper { def createStream( jssc: JavaStreamingContext, |