Skip to content

Commit 762af4e

Browse files
techaddictpwendell
authored andcommitted
SPARK-1467: Make StorageLevel.apply() factory methods Developer APIs
We may want to evolve these in the future to add things like SSDs, so let's mark them as experimental for now. Long-term the right solution might be some kind of builder. The stable API should be the existing StorageLevel constants. Author: Sandeep <[email protected]> Closes mesos#551 from techaddict/SPARK-1467 and squashes the following commits: 6bdda24 [Sandeep] SPARK-1467: Make StorageLevel.apply() factory methods as Developer Api's We may want to evolve these in the future to add things like SSDs, so let's mark them as experimental for now. Long-term the right solution might be some kind of builder. The stable API should be the existing StorageLevel constants.
1 parent 8e37ed6 commit 762af4e

File tree

1 file changed

+22
-4
lines changed

1 file changed

+22
-4
lines changed

core/src/main/scala/org/apache/spark/storage/StorageLevel.scala

Lines changed: 22 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,8 @@ package org.apache.spark.storage
1919

2020
import java.io.{Externalizable, IOException, ObjectInput, ObjectOutput}
2121

22+
import org.apache.spark.annotation.DeveloperApi
23+
2224
/**
2325
* Flags for controlling the storage of an RDD. Each StorageLevel records whether to use memory,
2426
* or Tachyon, whether to drop the RDD to disk if it falls out of memory or Tachyon , whether to
@@ -142,21 +144,37 @@ object StorageLevel {
142144
val MEMORY_AND_DISK_SER_2 = new StorageLevel(true, true, false, false, 2)
143145
val OFF_HEAP = new StorageLevel(false, false, true, false)
144146

145-
/** Create a new StorageLevel object without setting useOffHeap */
147+
/**
148+
* :: DeveloperApi ::
149+
* Create a new StorageLevel object without setting useOffHeap
150+
*/
151+
@DeveloperApi
146152
def apply(useDisk: Boolean, useMemory: Boolean, useOffHeap: Boolean,
147153
deserialized: Boolean, replication: Int) = getCachedStorageLevel(
148154
new StorageLevel(useDisk, useMemory, useOffHeap, deserialized, replication))
149155

150-
/** Create a new StorageLevel object */
156+
/**
157+
* :: DeveloperApi ::
158+
* Create a new StorageLevel object
159+
*/
160+
@DeveloperApi
151161
def apply(useDisk: Boolean, useMemory: Boolean,
152162
deserialized: Boolean, replication: Int = 1) = getCachedStorageLevel(
153163
new StorageLevel(useDisk, useMemory, false, deserialized, replication))
154164

155-
/** Create a new StorageLevel object from its integer representation */
165+
/**
166+
* :: DeveloperApi ::
167+
* Create a new StorageLevel object from its integer representation
168+
*/
169+
@DeveloperApi
156170
def apply(flags: Int, replication: Int): StorageLevel =
157171
getCachedStorageLevel(new StorageLevel(flags, replication))
158172

159-
/** Read StorageLevel object from ObjectInput stream */
173+
/**
174+
* :: DeveloperApi ::
175+
* Read StorageLevel object from ObjectInput stream
176+
*/
177+
@DeveloperApi
160178
def apply(in: ObjectInput): StorageLevel = {
161179
val obj = new StorageLevel()
162180
obj.readExternal(in)

0 commit comments

Comments
 (0)