func ToProtoStorageLevel()

in spark/sql/utils/consts.go [45:68]


func ToProtoStorageLevel(level StorageLevel) *proto.StorageLevel {
	switch level {
	case StorageLevelDiskOnly:
		return &proto.StorageLevel{UseDisk: true, UseMemory: false, Replication: 1}
	case StorageLevelDiskOnly2:
		return &proto.StorageLevel{UseDisk: true, UseMemory: false, Replication: 2}
	case StorageLevelDiskOnly3:
		return &proto.StorageLevel{UseDisk: true, UseMemory: false, Replication: 3}
	case StorageLevelMemoryAndDisk:
		return &proto.StorageLevel{UseDisk: true, UseMemory: true, Replication: 1}
	case StorageLevelMemoryAndDisk2:
		return &proto.StorageLevel{UseDisk: true, UseMemory: true, Replication: 2}
	case StorageLevelMemoryOnly:
		return &proto.StorageLevel{UseDisk: false, UseMemory: true, Replication: 1}
	case StorageLevelMemoryOnly2:
		return &proto.StorageLevel{UseDisk: false, UseMemory: true, Replication: 2}
	case StorageLevelMemoyAndDiskDeser:
		return &proto.StorageLevel{UseDisk: true, UseMemory: true, Replication: 1, Deserialized: true}
	case StorageLevelOffHeap:
		return &proto.StorageLevel{UseDisk: true, UseMemory: true, UseOffHeap: true, Replication: 1}
	default:
		return &proto.StorageLevel{UseDisk: false, UseMemory: false, UseOffHeap: false, Replication: 1}
	}
}