in spark/sql/utils/consts.go [70:98]
func FromProtoStorageLevel(level *proto.StorageLevel) StorageLevel {
if level.UseDisk && level.UseMemory && level.Replication <= 1 && !level.Deserialized && !level.UseOffHeap {
return StorageLevelMemoryAndDisk
} else if level.UseDisk && level.UseMemory && level.Replication == 2 && !level.Deserialized && !level.UseOffHeap {
return StorageLevelMemoryAndDisk2
} else if level.UseDisk && !level.UseMemory && level.Replication == 3 &&
!level.Deserialized && !level.UseOffHeap {
return StorageLevelDiskOnly3
} else if level.UseDisk && !level.UseMemory && level.Replication == 2 &&
!level.Deserialized && !level.UseOffHeap {
return StorageLevelDiskOnly2
} else if level.UseDisk && !level.UseMemory && level.Replication <= 1 &&
!level.Deserialized && !level.UseOffHeap {
return StorageLevelDiskOnly
} else if !level.UseDisk && level.UseMemory && level.Replication <= 1 &&
!level.Deserialized && !level.UseOffHeap {
return StorageLevelMemoryOnly
} else if !level.UseDisk && level.UseMemory && level.Replication == 2 &&
!level.Deserialized && !level.UseOffHeap {
return StorageLevelMemoryOnly2
} else if level.UseDisk && level.UseMemory && level.Replication <= 1 && level.Deserialized && !level.UseOffHeap {
return StorageLevelMemoyAndDiskDeser
} else if !level.UseDisk && !level.UseMemory && !level.Deserialized && !level.UseOffHeap {
return StorageLevelNone
} else if level.UseOffHeap && !level.Deserialized {
return StorageLevelOffHeap
}
return StorageLevelNone
}