Address code review comments

Signed-off-by: Andriy Redko <andriy.redko@aiven.io>

Author: reta

src/main/java/org/opensearch/index/codec/customcodecs/Lucene912QatStoredFieldsFormat.java

@@ -87,7 +87,7 @@ public Lucene912QatStoredFieldsFormat(Lucene912QatCodec.Mode mode, Supplier<QatZ
      */
     public Lucene912QatStoredFieldsFormat(Lucene912QatCodec.Mode mode, int compressionLevel, Supplier<QatZipper.Mode> supplier) {
         this.mode = Objects.requireNonNull(mode);
-        qatCompressionMode = new QatCompressionMode(mode, compressionLevel, supplier);
+        qatCompressionMode = new QatCompressionMode(getAlgorithm(mode), compressionLevel, supplier);
     }
 
     /**
@@ -176,4 +176,13 @@ public Lucene912QatCodec.Mode getMode() {
     public QatCompressionMode getCompressionMode() {
         return qatCompressionMode;
     }
+
+    /**
+     * Returns {@link QatZipper.Algorithm} instance that corresponds codec's {@link Lucene912QatCodec.Mode mode}
+     * @param mode codec's {@link Lucene912QatCodec.Mode mode}
+     * @return the {@link QatZipper.Algorithm} instance that corresponds codec's {@link Lucene912QatCodec.Mode mode}
+     */
+    private static QatZipper.Algorithm getAlgorithm(Lucene912QatCodec.Mode mode) {
+        return (mode == Lucene912QatCodec.Mode.QAT_LZ4) ? QatZipper.Algorithm.LZ4 : QatZipper.Algorithm.DEFLATE;
+    }
 }

src/main/java/org/opensearch/index/codec/customcodecs/QatCompressionMode.java

@@ -36,37 +36,37 @@ public class QatCompressionMode extends CompressionMode {
 
     /** default constructor */
     protected QatCompressionMode() {
-        this(Lucene912QatCodec.DEFAULT_COMPRESSION_MODE, DEFAULT_COMPRESSION_LEVEL, () -> { return DEFAULT_QAT_MODE; });
+        this(QatZipper.Algorithm.LZ4, DEFAULT_COMPRESSION_LEVEL, () -> { return DEFAULT_QAT_MODE; });
     }
 
     /**
      * Creates a new instance.
      *
-     * @param mode The compression mode (QAT_LZ4 or QAT_DEFLATE)
+     * @param algorithm The compression algorithm (LZ4 or DEFLATE)
      */
-    protected QatCompressionMode(Lucene912QatCodec.Mode mode) {
-        this(mode, DEFAULT_COMPRESSION_LEVEL, () -> { return DEFAULT_QAT_MODE; });
+    protected QatCompressionMode(QatZipper.Algorithm algorithm) {
+        this(algorithm, DEFAULT_COMPRESSION_LEVEL, () -> { return DEFAULT_QAT_MODE; });
     }
 
     /**
      * Creates a new instance.
      *
-     * @param mode The compression mode (QAT_LZ4 or QAT_DEFLATE)
+     * @param algorithm The compression algorithm (LZ4 or DEFLATE)
      * @param compressionLevel The compression level to use.
      */
-    protected QatCompressionMode(Lucene912QatCodec.Mode mode, int compressionLevel) {
-        this(mode, compressionLevel, () -> { return DEFAULT_QAT_MODE; });
+    protected QatCompressionMode(QatZipper.Algorithm algorithm, int compressionLevel) {
+        this(algorithm, compressionLevel, () -> { return DEFAULT_QAT_MODE; });
     }
 
     /**
      * Creates a new instance.
      *
-     * @param mode The compression mode (QAT_LZ4 or QAT_DEFLATE)
+     * @param algorithm The compression algorithm (LZ4 or DEFLATE)
      * @param compressionLevel The compression level to use.
      * @param supplier a supplier for QAT acceleration mode.
      */
-    protected QatCompressionMode(Lucene912QatCodec.Mode mode, int compressionLevel, Supplier<QatZipper.Mode> supplier) {
-        this.algorithm = mode == Lucene912QatCodec.Mode.QAT_LZ4 ? QatZipper.Algorithm.LZ4 : QatZipper.Algorithm.DEFLATE;
+    protected QatCompressionMode(QatZipper.Algorithm algorithm, int compressionLevel, Supplier<QatZipper.Mode> supplier) {
+        this.algorithm = algorithm;
         this.compressionLevel = compressionLevel;
         this.supplier = supplier;
     }

src/main/java/org/opensearch/index/codec/customcodecs/backward_codecs/lucene99/Lucene99QatStoredFieldsFormat.java

@@ -17,6 +17,7 @@
 import org.apache.lucene.index.SegmentInfo;
 import org.apache.lucene.store.Directory;
 import org.apache.lucene.store.IOContext;
+import org.opensearch.index.codec.customcodecs.QatCompressionMode;
 
 import java.io.IOException;
 import java.util.Objects;
@@ -84,7 +85,8 @@ public Lucene99QatStoredFieldsFormat(Lucene99QatCodec.Mode mode, Supplier<QatZip
      */
     public Lucene99QatStoredFieldsFormat(Lucene99QatCodec.Mode mode, int compressionLevel, Supplier<QatZipper.Mode> supplier) {
         this.mode = Objects.requireNonNull(mode);
-        qatCompressionMode = new QatCompressionMode(mode, compressionLevel, supplier);
+        qatCompressionMode = new QatCompressionMode(getAlgorithm(mode), compressionLevel, supplier) {
+        };
     }
 
     /**
@@ -173,4 +175,13 @@ public Lucene99QatCodec.Mode getMode() {
     public QatCompressionMode getCompressionMode() {
         return qatCompressionMode;
     }
+
+    /**
+     * Returns {@link QatZipper.Algorithm} instance that corresponds codec's {@link Lucene99QatCodec.Mode mode}
+     * @param mode codec's {@link Lucene99QatCodec.Mode mode}
+     * @return the {@link QatZipper.Algorithm} instance that corresponds codec's {@link Lucene99QatCodec.Mode mode}
+     */
+    private static QatZipper.Algorithm getAlgorithm(Lucene99QatCodec.Mode mode) {
+        return (mode == Lucene99QatCodec.Mode.QAT_LZ4) ? QatZipper.Algorithm.LZ4 : QatZipper.Algorithm.DEFLATE;
+    }
 }

src/main/java/org/opensearch/index/codec/customcodecs/backward_codecs/lucene99/QatCompressionMode.java

@@ -12,6 +12,8 @@
 
 import java.io.IOException;
 
+import com.intel.qat.QatZipper;
+
 import static org.hamcrest.Matchers.is;
 import static org.junit.Assume.assumeThat;
 
@@ -21,13 +23,13 @@ public class QatDeflateCompressorTests extends AbstractCompressorTests {
     @Override
     Compressor compressor() {
         assumeThat("Qat library is available", QatZipperFactory.isQatAvailable(), is(true));
-        return new QatCompressionMode(Lucene912QatCodec.Mode.QAT_DEFLATE).newCompressor();
+        return new QatCompressionMode(QatZipper.Algorithm.DEFLATE).newCompressor();
     }
 
     @Override
     Decompressor decompressor() {
         assumeThat("Qat library is available", QatZipperFactory.isQatAvailable(), is(true));
-        return new QatCompressionMode(Lucene912QatCodec.Mode.QAT_DEFLATE).newDecompressor();
+        return new QatCompressionMode(QatZipper.Algorithm.DEFLATE).newDecompressor();
     }
 
     @Override

src/test/java/org/opensearch/index/codec/customcodecs/QatDeflateCompressorTests.java

@@ -12,6 +12,8 @@
 
 import java.io.IOException;
 
+import com.intel.qat.QatZipper;
+
 import static org.hamcrest.Matchers.is;
 import static org.junit.Assume.assumeThat;
 
@@ -21,13 +23,13 @@ public class QatLz4CompressorTests extends AbstractCompressorTests {
     @Override
     Compressor compressor() {
         assumeThat("Qat library is available", QatZipperFactory.isQatAvailable(), is(true));
-        return new QatCompressionMode(Lucene912QatCodec.Mode.QAT_LZ4).newCompressor();
+        return new QatCompressionMode(QatZipper.Algorithm.LZ4).newCompressor();
     }
 
     @Override
     Decompressor decompressor() {
         assumeThat("Qat library is available", QatZipperFactory.isQatAvailable(), is(true));
-        return new QatCompressionMode(Lucene912QatCodec.Mode.QAT_LZ4).newDecompressor();
+        return new QatCompressionMode(QatZipper.Algorithm.LZ4).newDecompressor();
     }
 
     @Override

src/test/java/org/opensearch/index/codec/customcodecs/QatLz4CompressorTests.java

@@ -8,6 +8,7 @@
 
 package org.opensearch.index.codec.customcodecs.backward_codecs.lucene99;
 
+import org.opensearch.index.codec.customcodecs.QatCompressionMode;
 import org.opensearch.index.codec.customcodecs.QatZipperFactory;
 import org.opensearch.test.OpenSearchTestCase;