func FromProtoStorageLevel()

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
}