Moving zstd compression codec as a plugin

Signed-off-by: Sarthak Aggarwal <sarthagg@amazon.com>
sarthakaggarwal97 · Sep 1, 2023 · b300a90 · b300a90
1 parent 3c968f8
commit b300a90
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/.../reindex/src/internalClusterTest/java/org/opensearch/index/codec/MultiCodecReindexIT.java b/.../reindex/src/internalClusterTest/java/org/opensearch/index/codec/MultiCodecReindexIT.java
@@ -19,6 +19,7 @@
 import org.opensearch.index.engine.Segment;
 import org.opensearch.index.reindex.BulkByScrollResponse;
 import org.opensearch.index.reindex.ReindexAction;
+import org.opensearch.index.reindex.ReindexModulePlugin;
 import org.opensearch.index.reindex.ReindexRequestBuilder;
 import org.opensearch.index.reindex.ReindexTestCase;
 import org.opensearch.plugins.Plugin;
@@ -46,9 +47,7 @@ public class MultiCodecReindexIT extends ReindexTestCase {
 
     @Override
     protected Collection<Class<? extends Plugin>> nodePlugins() {
-        List<Class<? extends Plugin>> plugins = new ArrayList<>(super.nodePlugins());
-        plugins.add(CustomCodecPlugin.class);
-        return plugins;
+        return List.of(CustomCodecPlugin.class, ReindexModulePlugin.class);
     }
 
     public void testReindexingMultipleCodecs() throws InterruptedException, ExecutionException {

diff --git a/...custom-codecs/src/test/java/org/opensearch/index/codec/customcodecs/CustomCodecTests.java b/...custom-codecs/src/test/java/org/opensearch/index/codec/customcodecs/CustomCodecTests.java
@@ -178,7 +178,7 @@ private void assertStoredFieldsCompressionEquals(Lucene95CustomCodec.Mode expect
     private CodecService createCodecService(boolean isMapperServiceNull) throws IOException {
         Settings nodeSettings = Settings.builder().put(Environment.PATH_HOME_SETTING.getKey(), createTempDir()).build();
         if (isMapperServiceNull) {
-            return new CustomCodecService(null, IndexSettingsModule.newIndexSettings("_na", nodeSettings), LogManager.getLogger("test"));
+            return new CodecService(null, IndexSettingsModule.newIndexSettings("_na", nodeSettings), LogManager.getLogger("test"));
         }
         return buildCodecService(nodeSettings);
     }