Fix spotless

Signed-off-by: Austin Lee <[email protected]>
opensearch-project · Sep 1, 2023 · 8f4d90d · 8f4d90d
1 parent 1eb9444
commit 8f4d90d
Showing 1 changed file with 20 additions and 18 deletions.
diff --git a/plugin/src/main/java/org/opensearch/ml/plugin/MachineLearningPlugin.java b/plugin/src/main/java/org/opensearch/ml/plugin/MachineLearningPlugin.java
@@ -344,7 +344,8 @@ public Collection<Object> createComponents(
 
         // TODO move this into MLFeatureEnabledSetting
         this.ragSearchPipelineEnabled = ML_COMMONS_RAG_PIPELINE_FEATURE_ENABLED.get(clusterService.getSettings());
-        clusterService.getClusterSettings()
+        clusterService
+            .getClusterSettings()
             .addSettingsUpdateConsumer(ML_COMMONS_RAG_PIPELINE_FEATURE_ENABLED, it -> ragSearchPipelineEnabled = it);
 
         mlIndicesHandler = new MLIndicesHandler(clusterService, client);
@@ -677,31 +678,32 @@ public List<Setting<?>> getSettings() {
 
     @Override
     public List<SearchPlugin.SearchExtSpec<?>> getSearchExts() {
-        return ragSearchPipelineEnabled ? List
-            .of(
-                new SearchPlugin.SearchExtSpec<>(
-                    GenerativeQAParamExtBuilder.PARAMETER_NAME,
-                    input -> new GenerativeQAParamExtBuilder(input),
-                    parser -> GenerativeQAParamExtBuilder.parse(parser)
+        return ragSearchPipelineEnabled
+            ? List
+                .of(
+                    new SearchPlugin.SearchExtSpec<>(
+                        GenerativeQAParamExtBuilder.PARAMETER_NAME,
+                        input -> new GenerativeQAParamExtBuilder(input),
+                        parser -> GenerativeQAParamExtBuilder.parse(parser)
+                    )
                 )
-            )
-               // Feature not enabled
-               : Collections.emptyList();
+            // Feature not enabled
+            : Collections.emptyList();
     }
 
     @Override
     public Map<String, Processor.Factory<SearchRequestProcessor>> getRequestProcessors(Parameters parameters) {
-        return ragSearchPipelineEnabled ?
-               Map.of(GenerativeQAProcessorConstants.REQUEST_PROCESSOR_TYPE, new GenerativeQARequestProcessor.Factory())
-               // Feature not enabled
-               : Collections.emptyMap();
+        return ragSearchPipelineEnabled
+            ? Map.of(GenerativeQAProcessorConstants.REQUEST_PROCESSOR_TYPE, new GenerativeQARequestProcessor.Factory())
+            // Feature not enabled
+            : Collections.emptyMap();
     }
 
     @Override
     public Map<String, Processor.Factory<SearchResponseProcessor>> getResponseProcessors(Parameters parameters) {
-        return ragSearchPipelineEnabled ?
-            Map.of(GenerativeQAProcessorConstants.RESPONSE_PROCESSOR_TYPE, new GenerativeQAResponseProcessor.Factory(this.client))
-               // Feature not enabled
-               : Collections.emptyMap();
+        return ragSearchPipelineEnabled
+            ? Map.of(GenerativeQAProcessorConstants.RESPONSE_PROCESSOR_TYPE, new GenerativeQAResponseProcessor.Factory(this.client))
+            // Feature not enabled
+            : Collections.emptyMap();
     }
 }