fix code for renames + apply spotless formatting

Author: idickerson7

sdk/search/azure-search-documents/src/main/java/com/azure/search/documents/SearchIndexingBufferedSenderBuilder.java

@@ -221,8 +221,8 @@ public SearchIndexingBufferedSenderBuilder<T> throttlingDelay(Duration throttlin
     public SearchIndexingBufferedSenderBuilder<T> maxThrottlingDelay(Duration maxThrottlingDelay) {
         Objects.requireNonNull(maxThrottlingDelay, "'maxThrottlingDelay' cannot be null.");
         if (maxThrottlingDelay.isNegative() || maxThrottlingDelay.isZero()) {
-            throw LOGGER.logExceptionAsError(
-                new IllegalArgumentException("'maxThrottlingDelay' cannot be negative or zero."));
+            throw LOGGER
+                .logExceptionAsError(new IllegalArgumentException("'maxThrottlingDelay' cannot be negative or zero."));
         }
         this.maxThrottlingDelay = maxThrottlingDelay;
         return this;
@@ -356,4 +356,3 @@ public SearchIndexingBufferedSenderBuilder<T> retryPolicy(RetryPolicy retryPolic
         return this;
     }
 }
-

sdk/search/azure-search-documents/src/main/java/com/azure/search/documents/knowledgebases/KnowledgeBaseRetrievalAsyncClient.java

@@ -95,8 +95,9 @@ public SearchServiceVersion getServiceVersion() {
     @ServiceMethod(returns = ReturnType.SINGLE)
     public Mono<Response<KnowledgeBaseRetrievalResult>> retrieveWithResponse(String knowledgeBaseName,
         KnowledgeBaseRetrievalOptions retrievalRequest, RequestOptions requestOptions) {
-        return mapResponse(this.serviceClient.retrieveWithResponseAsync(
-            BinaryData.fromObject(retrievalRequest), requestOptions), KnowledgeBaseRetrievalResult.class);
+        return mapResponse(
+            this.serviceClient.retrieveWithResponseAsync(BinaryData.fromObject(retrievalRequest), requestOptions),
+            KnowledgeBaseRetrievalResult.class);
     }
 
     /**
@@ -269,7 +270,6 @@ public Mono<KnowledgeBaseRetrievalResult> retrieve(KnowledgeBaseRetrievalOptions
     @ServiceMethod(returns = ReturnType.SINGLE)
     public Mono<KnowledgeBaseRetrievalResult> retrieve(String knowledgeBaseName,
         KnowledgeBaseRetrievalOptions retrievalRequest) {
-        return retrieveWithResponse(knowledgeBaseName, retrievalRequest, new RequestOptions())
-            .map(Response::getValue);
+        return retrieveWithResponse(knowledgeBaseName, retrievalRequest, new RequestOptions()).map(Response::getValue);
     }
 }

sdk/search/azure-search-documents/src/main/java/com/azure/search/documents/knowledgebases/KnowledgeBaseRetrievalClient.java

@@ -92,8 +92,9 @@ public SearchServiceVersion getServiceVersion() {
     @ServiceMethod(returns = ReturnType.SINGLE)
     public Response<KnowledgeBaseRetrievalResult> retrieveWithResponse(String knowledgeBaseName,
         KnowledgeBaseRetrievalOptions retrievalRequest, RequestOptions requestOptions) {
-        return convertResponse(this.serviceClient.retrieveWithResponse(
-            BinaryData.fromObject(retrievalRequest), requestOptions), KnowledgeBaseRetrievalResult.class);
+        return convertResponse(
+            this.serviceClient.retrieveWithResponse(BinaryData.fromObject(retrievalRequest), requestOptions),
+            KnowledgeBaseRetrievalResult.class);
     }
 
     /**

sdk/search/azure-search-documents/src/test/java/com/azure/search/documents/KnowledgeBaseTests.java

@@ -391,8 +391,7 @@ public void basicRetrievalSync() {
         KnowledgeBaseRetrievalOptions retrievalRequest = new KnowledgeBaseRetrievalOptions()
             .setIntents(new KnowledgeRetrievalSemanticIntent("What are the pet policies at the hotel?"));
 
-        KnowledgeBaseRetrievalResult response
-            = knowledgeBaseClient.retrieve(knowledgeBase.getName(), retrievalRequest);
+        KnowledgeBaseRetrievalResult response = knowledgeBaseClient.retrieve(knowledgeBase.getName(), retrievalRequest);
         assertNotNull(response);
         assertNotNull(response.getResponse());
     }
@@ -437,8 +436,7 @@ public void basicRetrievalWithReasoningEffortSync() {
             .setIntents(new KnowledgeRetrievalSemanticIntent("What are the pet policies at the hotel?"));
         // .setRetrievalReasoningEffort(KnowledgeRetrievalReasoningEffortKind.MEDIUM);  // TODO: Missing enum
 
-        KnowledgeBaseRetrievalResult response
-            = knowledgeBaseClient.retrieve(knowledgeBase.getName(), retrievalRequest);
+        KnowledgeBaseRetrievalResult response = knowledgeBaseClient.retrieve(knowledgeBase.getName(), retrievalRequest);
         assertNotNull(response);
         assertNotNull(response.getResponse());
     }

sdk/search/azure-search-documents/src/test/java/com/azure/search/documents/indexes/DataSourceTests.java

@@ -139,8 +139,7 @@ public void canCreateAndListDataSourcesWithResponseSync() {
         client.createOrUpdateDataSourceConnectionWithResponse(dataSource2, null);
         dataSourcesToDelete.add(dataSource2.getName());
 
-        Set<String> actualDataSources
-            = client.listDataSourceConnectionNames().stream().collect(Collectors.toSet());
+        Set<String> actualDataSources = client.listDataSourceConnectionNames().stream().collect(Collectors.toSet());
 
         assertEquals(expectedDataSources.size(), actualDataSources.size());
         expectedDataSources.forEach(ds -> assertTrue(actualDataSources.contains(ds), "Missing expected data source."));

sdk/search/azure-search-documents/src/test/java/com/azure/search/documents/indexes/SkillsetManagementTests.java

@@ -483,17 +483,17 @@ public void canListSkillsetsWithSelectedFieldSyncAndAsync() {
         skillsetsToDelete.add(skillset2.getName());
 
         Set<String> expectedSkillsetNames = new HashSet<>(Arrays.asList(skillset1.getName(), skillset2.getName()));
-        Set<String> actualSkillsetNames
-            = client.listSkillsetNames().stream().collect(Collectors.toSet());
+        Set<String> actualSkillsetNames = client.listSkillsetNames().stream().collect(Collectors.toSet());
 
         assertEquals(expectedSkillsetNames.size(), actualSkillsetNames.size());
         assertTrue(actualSkillsetNames.containsAll(expectedSkillsetNames));
 
         StepVerifier.create(asyncClient.listSkillsetNames().collect(Collectors.toSet()))
             .assertNext(actualSkillsetNamesAsync -> {
-            assertEquals(actualSkillsetNamesAsync.size(), actualSkillsetNames.size());
-            assertTrue(actualSkillsetNamesAsync.containsAll(expectedSkillsetNames));
-        }).verifyComplete();
+                assertEquals(actualSkillsetNamesAsync.size(), actualSkillsetNames.size());
+                assertTrue(actualSkillsetNamesAsync.containsAll(expectedSkillsetNames));
+            })
+            .verifyComplete();
     }
 
     @Test

sdk/search/azure-search-documents/src/test/java/com/azure/search/documents/indexes/SynonymMapManagementTests.java

@@ -495,17 +495,17 @@ public void canListSynonymMapsWithSelectedFieldSyncAndAsync() {
         synonymMapsToDelete.add(synonymMap2.getName());
 
         Set<String> expectedSynonymNames = new HashSet<>(Arrays.asList(synonymMap1.getName(), synonymMap2.getName()));
-        Set<String> actualSynonymNames
-            = client.listSynonymMapNames().stream().collect(Collectors.toSet());
+        Set<String> actualSynonymNames = client.listSynonymMapNames().stream().collect(Collectors.toSet());
 
         assertEquals(expectedSynonymNames.size(), actualSynonymNames.size());
         assertTrue(actualSynonymNames.containsAll(expectedSynonymNames));
 
         StepVerifier.create(asyncClient.listSynonymMapNames().collect(Collectors.toSet()))
             .assertNext(actualSynonymNames2 -> {
-            assertEquals(expectedSynonymNames.size(), actualSynonymNames2.size());
-            assertTrue(actualSynonymNames2.containsAll(expectedSynonymNames));
-        }).verifyComplete();
+                assertEquals(expectedSynonymNames.size(), actualSynonymNames2.size());
+                assertTrue(actualSynonymNames2.containsAll(expectedSynonymNames));
+            })
+            .verifyComplete();
     }
 
     @Test

sdk/search/azure-search-documents/src/test/java/com/azure/search/documents/models/SearchRequestUrlRewriterPolicyTests.java

@@ -198,11 +198,11 @@ public HttpResponse sendSync(HttpRequest request, Context context) {
                 dataSourceUrl),
             Arguments.of(toCallable(() -> indexerClient.createDataSourceConnectionWithResponse(dataSource, null)),
                 dataSourcesUrl),
-            Arguments.of(toCallable(() -> indexerClient.getDataSourceConnectionWithResponse("datasource", null)),
-                dataSourceUrl),
-            Arguments.of(toCallable(indexerClient::listDataSourceConnections), dataSourcesUrl),
             Arguments.of(
-                toCallable(() -> indexerClient.listDataSourceConnectionNames().iterator().hasNext()), dataSourcesUrl),
+                toCallable(() -> indexerClient.getDataSourceConnectionWithResponse("datasource", null)), dataSourceUrl),
+            Arguments.of(toCallable(indexerClient::listDataSourceConnections), dataSourcesUrl),
+            Arguments.of(toCallable(() -> indexerClient.listDataSourceConnectionNames().iterator().hasNext()),
+                dataSourcesUrl),
             Arguments.of(
                 toCallable(() -> indexerClient.deleteDataSourceConnectionWithResponse(dataSource.getName(), null)),
                 dataSourceUrl),