|
25 | 25 | import java.util.Arrays;
|
26 | 26 | import java.util.Collection;
|
27 | 27 | import java.util.Collections;
|
| 28 | +import java.util.HashMap; |
28 | 29 | import java.util.List;
|
29 | 30 | import java.util.Map;
|
30 | 31 | import java.util.UUID;
|
@@ -52,30 +53,24 @@ protected Collection<Class<? extends Plugin>> nodePlugins() {
|
52 | 53 |
|
53 | 54 | public void testForceMergeMultipleCodecs() throws ExecutionException, InterruptedException {
|
54 | 55 |
|
55 |
| - Map<String, String> codecMap = Map.of( |
56 |
| - "best_compression", |
57 |
| - "BEST_COMPRESSION", |
58 |
| - "zlib", |
59 |
| - "BEST_COMPRESSION", |
60 |
| - "zstd_no_dict", |
61 |
| - "ZSTD_NO_DICT", |
62 |
| - "zstd", |
63 |
| - "ZSTD", |
64 |
| - "default", |
65 |
| - "BEST_SPEED", |
66 |
| - "lz4", |
67 |
| - "BEST_SPEED" |
68 |
| - ); |
69 |
| - |
70 |
| - if (QatZipperFactory.isQatAvailable()) { |
71 |
| - codecMap.put("QAT_LZ4", "qat_lz4"); |
72 |
| - codecMap.put("QAT_DEFLATE", "qat_deflate"); |
73 |
| - } |
| 56 | + Map<String, String> codecMap = new HashMap<String, String>() { |
| 57 | + { |
| 58 | + put("best_compression", "BEST_COMPRESSION"); |
| 59 | + put("zlib", "BEST_COMPRESSION"); |
| 60 | + put("zstd_no_dict", "ZSTD_NO_DICT"); |
| 61 | + put("zstd", "ZSTD"); |
| 62 | + put("default", "BEST_SPEED"); |
| 63 | + put("lz4", "BEST_SPEED"); |
| 64 | + if (QatZipperFactory.isQatAvailable()) { |
| 65 | + put("qat_lz4", "QAT_LZ4"); |
| 66 | + put("qat_deflate", "QAT_DEFLATE"); |
| 67 | + } |
| 68 | + } |
| 69 | + }; |
74 | 70 |
|
75 | 71 | for (Map.Entry<String, String> codec : codecMap.entrySet()) {
|
76 | 72 | forceMergeMultipleCodecs(codec.getKey(), codec.getValue(), codecMap);
|
77 | 73 | }
|
78 |
| - |
79 | 74 | }
|
80 | 75 |
|
81 | 76 | private void forceMergeMultipleCodecs(String finalCodec, String finalCodecMode, Map<String, String> codecMap) throws ExecutionException,
|
|
0 commit comments