0001
0002
0003
0004
0005
0006
0007
0008
0009
0010
0011
0012
0013
0014
0015
0016
0017
0018 package org.apache.spark.api.java;
0019
0020 import org.apache.spark.storage.StorageLevel;
0021
0022
0023
0024
0025 public class StorageLevels {
0026 public static final StorageLevel NONE = create(false, false, false, false, 1);
0027 public static final StorageLevel DISK_ONLY = create(true, false, false, false, 1);
0028 public static final StorageLevel DISK_ONLY_2 = create(true, false, false, false, 2);
0029 public static final StorageLevel MEMORY_ONLY = create(false, true, false, true, 1);
0030 public static final StorageLevel MEMORY_ONLY_2 = create(false, true, false, true, 2);
0031 public static final StorageLevel MEMORY_ONLY_SER = create(false, true, false, false, 1);
0032 public static final StorageLevel MEMORY_ONLY_SER_2 = create(false, true, false, false, 2);
0033 public static final StorageLevel MEMORY_AND_DISK = create(true, true, false, true, 1);
0034 public static final StorageLevel MEMORY_AND_DISK_2 = create(true, true, false, true, 2);
0035 public static final StorageLevel MEMORY_AND_DISK_SER = create(true, true, false, false, 1);
0036 public static final StorageLevel MEMORY_AND_DISK_SER_2 = create(true, true, false, false, 2);
0037 public static final StorageLevel OFF_HEAP = create(true, true, true, false, 1);
0038
0039
0040
0041
0042
0043
0044
0045
0046
0047 public static StorageLevel create(
0048 boolean useDisk,
0049 boolean useMemory,
0050 boolean useOffHeap,
0051 boolean deserialized,
0052 int replication) {
0053 return StorageLevel.apply(useDisk, useMemory, useOffHeap, deserialized, replication);
0054 }
0055 }