From d3c7be0cef747eb93fd0bdc198fdcef6e0e8c2cb Mon Sep 17 00:00:00 2001
From: Ankit Jain <jain.ankitk@gmail.com>
Date: Tue, 24 May 2022 22:48:25 -0700
Subject: [PATCH 1/2] Removing unused method from TransportSearchAction

Signed-off-by: Ankit Jain <jain.ankitk@gmail.com>
---
 .../action/search/TransportSearchAction.java  | 75 -------------------
 1 file changed, 75 deletions(-)

diff --git a/server/src/main/java/org/opensearch/action/search/TransportSearchAction.java b/server/src/main/java/org/opensearch/action/search/TransportSearchAction.java
index 1ca477942cdf6..ecb009b3d224b 100644
--- a/server/src/main/java/org/opensearch/action/search/TransportSearchAction.java
+++ b/server/src/main/java/org/opensearch/action/search/TransportSearchAction.java
@@ -298,81 +298,6 @@ void executeOnShardTarget(
         );
     }
 
-    public void executeRequest(
-        Task task,
-        SearchRequest searchRequest,
-        String actionName,
-        boolean includeSearchContext,
-        SinglePhaseSearchAction phaseSearchAction,
-        ActionListener<SearchResponse> listener
-    ) {
-        executeRequest(task, searchRequest, new SearchAsyncActionProvider() {
-            @Override
-            public AbstractSearchAsyncAction<? extends SearchPhaseResult> asyncSearchAction(
-                SearchTask task,
-                SearchRequest searchRequest,
-                Executor executor,
-                GroupShardsIterator<SearchShardIterator> shardsIts,
-                SearchTimeProvider timeProvider,
-                BiFunction<String, String, Transport.Connection> connectionLookup,
-                ClusterState clusterState,
-                Map<String, AliasFilter> aliasFilter,
-                Map<String, Float> concreteIndexBoosts,
-                Map<String, Set<String>> indexRoutings,
-                ActionListener<SearchResponse> listener,
-                boolean preFilter,
-                ThreadPool threadPool,
-                SearchResponse.Clusters clusters
-            ) {
-                return new AbstractSearchAsyncAction<SearchPhaseResult>(
-                    actionName,
-                    logger,
-                    searchTransportService,
-                    connectionLookup,
-                    aliasFilter,
-                    concreteIndexBoosts,
-                    indexRoutings,
-                    executor,
-                    searchRequest,
-                    listener,
-                    shardsIts,
-                    timeProvider,
-                    clusterState,
-                    task,
-                    new ArraySearchPhaseResults<>(shardsIts.size()),
-                    searchRequest.getMaxConcurrentShardRequests(),
-                    clusters
-                ) {
-                    @Override
-                    protected void executePhaseOnShard(
-                        SearchShardIterator shardIt,
-                        SearchShardTarget shard,
-                        SearchActionListener<SearchPhaseResult> listener
-                    ) {
-                        final Transport.Connection connection = getConnection(shard.getClusterAlias(), shard.getNodeId());
-                        phaseSearchAction.executeOnShardTarget(task, shard, connection, listener);
-                    }
-
-                    @Override
-                    protected SearchPhase getNextPhase(SearchPhaseResults<SearchPhaseResult> results, SearchPhaseContext context) {
-                        return new SearchPhase(getName()) {
-                            @Override
-                            public void run() {
-                                final AtomicArray<SearchPhaseResult> atomicArray = results.getAtomicArray();
-                                sendSearchResponse(InternalSearchResponse.empty(), atomicArray);
-                            }
-                        };
-                    }
-
-                    @Override
-                    boolean buildPointInTimeFromSearchResults() {
-                        return includeSearchContext;
-                    }
-                };
-            }
-        }, listener);
-    }
-
     private void executeRequest(
         Task task,
         SearchRequest searchRequest,

From a7445fdc20c8095bcc1ef05f61b730456204e68a Mon Sep 17 00:00:00 2001
From: Ankit Jain <jain.ankitk@gmail.com>
Date: Tue, 24 May 2022 23:03:57 -0700
Subject: [PATCH 2/2] Fixing gradle precommit violations

Signed-off-by: Ankit Jain <jain.ankitk@gmail.com>
---
 .../java/org/opensearch/action/search/TransportSearchAction.java | 1 -
 1 file changed, 1 deletion(-)

diff --git a/server/src/main/java/org/opensearch/action/search/TransportSearchAction.java b/server/src/main/java/org/opensearch/action/search/TransportSearchAction.java
index ecb009b3d224b..ebb0f21d6fe16 100644
--- a/server/src/main/java/org/opensearch/action/search/TransportSearchAction.java
+++ b/server/src/main/java/org/opensearch/action/search/TransportSearchAction.java
@@ -65,7 +65,6 @@
 import org.opensearch.common.settings.Setting;
 import org.opensearch.common.settings.Setting.Property;
 import org.opensearch.common.unit.TimeValue;
-import org.opensearch.common.util.concurrent.AtomicArray;
 import org.opensearch.common.util.concurrent.CountDown;
 import org.opensearch.index.Index;
 import org.opensearch.index.query.Rewriteable;