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}
}
}