spotlessApply

Signed-off-by: Nicholas Walter Knize <nknize@apache.org>
opensearch-project · Oct 19, 2021 · df28fdf · df28fdf
1 parent ee4aaf8
commit df28fdf
Show file tree

Hide file tree

Showing 2 changed files with 56 additions and 19 deletions.
diff --git a/server/src/main/java/org/opensearch/index/engine/EngineConfigFactory.java b/server/src/main/java/org/opensearch/index/engine/EngineConfigFactory.java
@@ -62,30 +62,66 @@ public EngineConfigFactory(PluginsService pluginsService, IndexSettings idxSetti
                 codecService = enginePlugin.getCustomCodecService(idxSettings);
                 codecServiceOverridingPlugin = enginePlugin.getClass().getName();
             } else {
-                throw new IllegalStateException("existing codec service already overridden in: " + codecServiceOverridingPlugin
-                    + " attempting to override again by: " + enginePlugin.getClass().getName());
+                throw new IllegalStateException(
+                    "existing codec service already overridden in: "
+                        + codecServiceOverridingPlugin
+                        + " attempting to override again by: "
+                        + enginePlugin.getClass().getName()
+                );
             }
         }
         this.codecService = codecService;
     }
 
     /** Insantiates a new EngineConfig from the provided custom overrides */
-    public EngineConfig newEngineConfig(ShardId shardId, ThreadPool threadPool,
-                                        IndexSettings indexSettings, Engine.Warmer warmer, Store store,
-                                        MergePolicy mergePolicy, Analyzer analyzer,
-                                        Similarity similarity, CodecService codecService, Engine.EventListener eventListener,
-                                        QueryCache queryCache, QueryCachingPolicy queryCachingPolicy, TranslogConfig translogConfig,
-                                        TimeValue flushMergesAfter,
-                                        List<ReferenceManager.RefreshListener> externalRefreshListener,
-                                        List<ReferenceManager.RefreshListener> internalRefreshListener, Sort indexSort,
-                                        CircuitBreakerService circuitBreakerService, LongSupplier globalCheckpointSupplier,
-                                        Supplier<RetentionLeases> retentionLeasesSupplier,
-                                        LongSupplier primaryTermSupplier,
-                                        EngineConfig.TombstoneDocSupplier tombstoneDocSupplier) {
+    public EngineConfig newEngineConfig(
+        ShardId shardId,
+        ThreadPool threadPool,
+        IndexSettings indexSettings,
+        Engine.Warmer warmer,
+        Store store,
+        MergePolicy mergePolicy,
+        Analyzer analyzer,
+        Similarity similarity,
+        CodecService codecService,
+        Engine.EventListener eventListener,
+        QueryCache queryCache,
+        QueryCachingPolicy queryCachingPolicy,
+        TranslogConfig translogConfig,
+        TimeValue flushMergesAfter,
+        List<ReferenceManager.RefreshListener> externalRefreshListener,
+        List<ReferenceManager.RefreshListener> internalRefreshListener,
+        Sort indexSort,
+        CircuitBreakerService circuitBreakerService,
+        LongSupplier globalCheckpointSupplier,
+        Supplier<RetentionLeases> retentionLeasesSupplier,
+        LongSupplier primaryTermSupplier,
+        EngineConfig.TombstoneDocSupplier tombstoneDocSupplier
+    ) {
 
-        return new EngineConfig(shardId, threadPool, indexSettings, warmer, store, mergePolicy, analyzer, similarity,
-            this.codecService.isPresent() == true ? this.codecService.get() : codecService, eventListener, queryCache,
-            queryCachingPolicy, translogConfig, flushMergesAfter, externalRefreshListener, internalRefreshListener, indexSort,
-            circuitBreakerService, globalCheckpointSupplier, retentionLeasesSupplier, primaryTermSupplier, tombstoneDocSupplier);
+        return new EngineConfig(
+            shardId,
+            threadPool,
+            indexSettings,
+            warmer,
+            store,
+            mergePolicy,
+            analyzer,
+            similarity,
+            this.codecService.isPresent() == true ? this.codecService.get() : codecService,
+            eventListener,
+            queryCache,
+            queryCachingPolicy,
+            translogConfig,
+            flushMergesAfter,
+            externalRefreshListener,
+            internalRefreshListener,
+            indexSort,
+            circuitBreakerService,
+            globalCheckpointSupplier,
+            retentionLeasesSupplier,
+            primaryTermSupplier,
+            tombstoneDocSupplier
+        );
     }
 }
diff --git a/server/src/test/java/org/opensearch/index/shard/IndexShardTests.java b/server/src/test/java/org/opensearch/index/shard/IndexShardTests.java
@@ -4702,7 +4702,8 @@ public void testDoNotTrimCommitsWhenOpenReadOnlyEngine() throws Exception {
                 protected void ensureMaxSeqNoEqualsToGlobalCheckpoint(SeqNoStats seqNoStats) {
                     // just like a following shard, we need to skip this check for now.
                 }
-            }, shard.getEngineConfigFactory()
+            },
+            shard.getEngineConfigFactory()
         );
         DiscoveryNode localNode = new DiscoveryNode("foo", buildNewFakeTransportAddress(), emptyMap(), emptySet(), Version.CURRENT);
         readonlyShard.markAsRecovering("store", new RecoveryState(readonlyShard.routingEntry(), localNode, null));