aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main/java
diff options
context:
space:
mode:
authorTathagata Das <tathagata.das1565@gmail.com>2015-08-24 12:40:09 -0700
committerTathagata Das <tathagata.das1565@gmail.com>2015-08-24 12:40:09 -0700
commit7478c8b66d6a2b1179f20c38b49e27e37b0caec3 (patch)
tree252ac13596be6d9d4be7fedb63cb08d25b063f6e /streaming/src/main/java
parent4e0395ddb764d092b5b38447af49e196e590e0f0 (diff)
downloadspark-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 'streaming/src/main/java')
-rw-r--r--streaming/src/main/java/org/apache/spark/streaming/util/WriteAheadLog.java2
-rw-r--r--streaming/src/main/java/org/apache/spark/streaming/util/WriteAheadLogRecordHandle.java2
2 files changed, 4 insertions, 0 deletions
diff --git a/streaming/src/main/java/org/apache/spark/streaming/util/WriteAheadLog.java b/streaming/src/main/java/org/apache/spark/streaming/util/WriteAheadLog.java
index 8c0fdfa9c7..3738fc1a23 100644
--- a/streaming/src/main/java/org/apache/spark/streaming/util/WriteAheadLog.java
+++ b/streaming/src/main/java/org/apache/spark/streaming/util/WriteAheadLog.java
@@ -21,6 +21,8 @@ import java.nio.ByteBuffer;
import java.util.Iterator;
/**
+ * :: DeveloperApi ::
+ *
* This abstract class represents a write ahead log (aka journal) that is used by Spark Streaming
* to save the received data (by receivers) and associated metadata to a reliable storage, so that
* they can be recovered after driver failures. See the Spark documentation for more information
diff --git a/streaming/src/main/java/org/apache/spark/streaming/util/WriteAheadLogRecordHandle.java b/streaming/src/main/java/org/apache/spark/streaming/util/WriteAheadLogRecordHandle.java
index 02324189b7..662889e779 100644
--- a/streaming/src/main/java/org/apache/spark/streaming/util/WriteAheadLogRecordHandle.java
+++ b/streaming/src/main/java/org/apache/spark/streaming/util/WriteAheadLogRecordHandle.java
@@ -18,6 +18,8 @@
package org.apache.spark.streaming.util;
/**
+ * :: DeveloperApi ::
+ *
* This abstract class represents a handle that refers to a record written in a
* {@link org.apache.spark.streaming.util.WriteAheadLog WriteAheadLog}.
* It must contain all the information necessary for the record to be read and returned by