@@ -95,7 +95,7 @@ func MakeIngestionWriterOptions(ctx context.Context, cs *cluster.Settings) sstab
95
95
// There are other, more specific, use cases that may call for a different
96
96
// algorithm, which can be set by overriding the default (see
97
97
// MakeIngestionSSTWriterWithOverrides).
98
- opts .Compression = getCompressionAlgorithm (ctx , cs , CompressionAlgorithmStorage )
98
+ opts .Compression = getCompressionProfile (ctx , cs , CompressionAlgorithmStorage )
99
99
opts .MergerName = "nullptr"
100
100
if ! IngestionValueBlocksEnabled .Get (& cs .SV ) {
101
101
opts .DisableValueBlocks = true
@@ -142,7 +142,7 @@ func MakeTransportSSTWriter(ctx context.Context, cs *cluster.Settings, f io.Writ
142
142
// block checksums and more index entries are just overhead and smaller blocks
143
143
// reduce compression ratio.
144
144
opts .BlockSize = 128 << 10
145
- opts .Compression = getCompressionAlgorithm (ctx , cs , CompressionAlgorithmBackupTransport )
145
+ opts .Compression = getCompressionProfile (ctx , cs , CompressionAlgorithmBackupTransport )
146
146
opts .MergerName = "nullptr"
147
147
return SSTWriter {
148
148
fw : sstable .NewWriter (& noopFinishAbort {f }, opts ),
@@ -174,7 +174,7 @@ func WithCompressionFromClusterSetting(
174
174
ctx context.Context , cs * cluster.Settings , setting * settings.EnumSetting [CompressionAlgorithm ],
175
175
) SSTWriterOption {
176
176
return func (opts * sstable.WriterOptions ) {
177
- opts .Compression = getCompressionAlgorithm (ctx , cs , setting )
177
+ opts .Compression = getCompressionProfile (ctx , cs , setting )
178
178
}
179
179
}
180
180
0 commit comments