Skip to content

Commit e554b1e

Browse files
committed
add python code
1 parent 47304b3 commit e554b1e

File tree

2 files changed

+13
-12
lines changed

2 files changed

+13
-12
lines changed

core/src/main/java/org/apache/spark/api/java/StorageLevels.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,6 @@ public class StorageLevels {
3434
public static final StorageLevel MEMORY_AND_DISK_2 = new StorageLevel(true, true, false, true, 2);
3535
public static final StorageLevel MEMORY_AND_DISK_SER = new StorageLevel(true, true, false, false, 1);
3636
public static final StorageLevel MEMORY_AND_DISK_SER_2 = new StorageLevel(true, true, false, false, 2);
37-
3837
public static final StorageLevel TACHYON = new StorageLevel(false, false, true, false, 1);
3938

4039
/**

python/pyspark/storagelevel.py

Lines changed: 13 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -25,23 +25,25 @@ class StorageLevel:
2525
Also contains static constants for some commonly used storage levels, such as MEMORY_ONLY.
2626
"""
2727

28-
def __init__(self, useDisk, useMemory, deserialized, replication = 1):
28+
def __init__(self, useDisk, useMemory, useTachyon, deserialized, replication = 1):
2929
self.useDisk = useDisk
3030
self.useMemory = useMemory
31+
self.useTachyon = useTachyon
3132
self.deserialized = deserialized
3233
self.replication = replication
3334

3435
def __repr__(self):
3536
return "StorageLevel(%s, %s, %s, %s)" % (
3637
self.useDisk, self.useMemory, self.deserialized, self.replication)
3738

38-
StorageLevel.DISK_ONLY = StorageLevel(True, False, False)
39-
StorageLevel.DISK_ONLY_2 = StorageLevel(True, False, False, 2)
40-
StorageLevel.MEMORY_ONLY = StorageLevel(False, True, True)
41-
StorageLevel.MEMORY_ONLY_2 = StorageLevel(False, True, True, 2)
42-
StorageLevel.MEMORY_ONLY_SER = StorageLevel(False, True, False)
43-
StorageLevel.MEMORY_ONLY_SER_2 = StorageLevel(False, True, False, 2)
44-
StorageLevel.MEMORY_AND_DISK = StorageLevel(True, True, True)
45-
StorageLevel.MEMORY_AND_DISK_2 = StorageLevel(True, True, True, 2)
46-
StorageLevel.MEMORY_AND_DISK_SER = StorageLevel(True, True, False)
47-
StorageLevel.MEMORY_AND_DISK_SER_2 = StorageLevel(True, True, False, 2)
39+
StorageLevel.DISK_ONLY = StorageLevel(True, False, False, False)
40+
StorageLevel.DISK_ONLY_2 = StorageLevel(True, False, False, False, 2)
41+
StorageLevel.MEMORY_ONLY = StorageLevel(False, True, False, True)
42+
StorageLevel.MEMORY_ONLY_2 = StorageLevel(False, True, False, True, 2)
43+
StorageLevel.MEMORY_ONLY_SER = StorageLevel(False, True, False, False)
44+
StorageLevel.MEMORY_ONLY_SER_2 = StorageLevel(False, True, False, False, 2)
45+
StorageLevel.MEMORY_AND_DISK = StorageLevel(True, True, False, True)
46+
StorageLevel.MEMORY_AND_DISK_2 = StorageLevel(True, True, False, True, 2)
47+
StorageLevel.MEMORY_AND_DISK_SER = StorageLevel(True, True, False, False)
48+
StorageLevel.MEMORY_AND_DISK_SER_2 = StorageLevel(True, True, False, False, 2)
49+
StorageLevel.TACHYON = StorageLevel(False, False, True, False, 1)

0 commit comments

Comments
 (0)