Remove unused parameter

trinodb · Oct 2, 2019 · 4d0dae6 · 4d0dae6
1 parent 6f833e0
commit 4d0dae6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/presto-elasticsearch/src/main/java/io/prestosql/elasticsearch/ElasticsearchClient.java b/presto-elasticsearch/src/main/java/io/prestosql/elasticsearch/ElasticsearchClient.java
@@ -194,7 +194,7 @@ public List<String> getIndices(ElasticsearchTableDescription tableDescription)
                 .collect(toImmutableList());
     }
 
-    public ClusterSearchShardsResponse getSearchShards(String index, ElasticsearchTableDescription tableDescription)
+    public ClusterSearchShardsResponse getSearchShards(String index)
     {
         verifyNotNull(client, "client is null");
         return getSearchShardsResponse(client, new ClusterSearchShardsRequest(index));

diff --git a/presto-elasticsearch/src/main/java/io/prestosql/elasticsearch/ElasticsearchSplitManager.java b/presto-elasticsearch/src/main/java/io/prestosql/elasticsearch/ElasticsearchSplitManager.java
@@ -53,7 +53,7 @@ public ConnectorSplitSource getSplits(ConnectorTransactionHandle transactionHand
         List<String> indices = client.getIndices(tableDescription);
         ImmutableList.Builder<ConnectorSplit> splits = ImmutableList.builder();
         for (String index : indices) {
-            ClusterSearchShardsResponse response = client.getSearchShards(index, tableDescription);
+            ClusterSearchShardsResponse response = client.getSearchShards(index);
             DiscoveryNode[] nodes = response.getNodes();
             for (ClusterSearchShardsGroup group : response.getGroups()) {
                 int nodeIndex = group.getShardId().getId() % nodes.length;