summaryrefslogtreecommitdiffstats
path: root/filedistribution
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-12-01 07:36:44 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2022-12-01 07:36:44 +0100
commit00e7d63e41842231528343a6e80ede595d997ff5 (patch)
treed611749f67d8ac3201b1a39b516339755715f236 /filedistribution
parentc42b104ac2a231cb120719dd904d5ad2ac31fbeb (diff)
- Reduce usage of guava.
- Ensure that tests relying on order are determinsitic.
Diffstat (limited to 'filedistribution')
-rw-r--r--filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceCompressor.java26
1 files changed, 10 insertions, 16 deletions
diff --git a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceCompressor.java b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceCompressor.java
index b6f84b979f5..0c3e69141e9 100644
--- a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceCompressor.java
+++ b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceCompressor.java
@@ -121,14 +121,11 @@ public class FileReferenceCompressor {
switch (type) {
case compressed:
log.log(Level.FINE, () -> "Compressing with compression type " + compressionType);
- switch (compressionType) {
- case gzip:
- return new GZIPOutputStream(new FileOutputStream(outputFile));
- case lz4:
- return new LZ4BlockOutputStream(new FileOutputStream(outputFile));
- default:
- throw new RuntimeException("Unknown compression type " + compressionType);
- }
+ return switch (compressionType) {
+ case gzip -> new GZIPOutputStream(new FileOutputStream(outputFile));
+ case lz4 -> new LZ4BlockOutputStream(new FileOutputStream(outputFile));
+ default -> throw new RuntimeException("Unknown compression type " + compressionType);
+ };
case file:
return new FileOutputStream(outputFile);
default:
@@ -140,14 +137,11 @@ public class FileReferenceCompressor {
switch (type) {
case compressed:
log.log(Level.FINE, () -> "Decompressing with compression type " + compressionType);
- switch (compressionType) {
- case gzip:
- return new GZIPInputStream(new FileInputStream(inputFile));
- case lz4:
- return new LZ4BlockInputStream(new FileInputStream(inputFile));
- default:
- throw new RuntimeException("Unknown compression type " + compressionType);
- }
+ return switch (compressionType) {
+ case gzip -> new GZIPInputStream(new FileInputStream(inputFile));
+ case lz4 -> new LZ4BlockInputStream(new FileInputStream(inputFile));
+ default -> throw new RuntimeException("Unknown compression type " + compressionType);
+ };
case file:
return new FileInputStream(inputFile);
default: