[Rename] ElasticsearchClient class in server module (#166)

This commit refactors the ElasticsearchClient class located in the server module to
OpenSearchClient. References and usages throughout the rest of the codebase are
fully refactored.

Signed-off-by: Nicholas Knize <nknize@amazon.com>
This commit is contained in:
Nick Knize 2021-03-03 14:29:06 -06:00
parent ccceb381db
commit e8b5a411a5
116 changed files with 282 additions and 282 deletions

View File

@ -21,7 +21,7 @@ package org.elasticsearch.script.mustache;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.script.ScriptType;
import java.util.Map;
@ -29,11 +29,11 @@ import java.util.Map;
public class SearchTemplateRequestBuilder
extends ActionRequestBuilder<SearchTemplateRequest, SearchTemplateResponse> {
SearchTemplateRequestBuilder(ElasticsearchClient client, SearchTemplateAction action) {
SearchTemplateRequestBuilder(OpenSearchClient client, SearchTemplateAction action) {
super(client, action, new SearchTemplateRequest());
}
public SearchTemplateRequestBuilder(ElasticsearchClient client) {
public SearchTemplateRequestBuilder(OpenSearchClient client) {
this(client, SearchTemplateAction.INSTANCE);
}

View File

@ -21,12 +21,12 @@ package org.elasticsearch.index.rankeval;
import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class RankEvalRequestBuilder extends ActionRequestBuilder<RankEvalRequest, RankEvalResponse> {
public RankEvalRequestBuilder(ElasticsearchClient client, ActionType<RankEvalResponse> action,
RankEvalRequest request) {
public RankEvalRequestBuilder(OpenSearchClient client, ActionType<RankEvalResponse> action,
RankEvalRequest request) {
super(client, action, request);
}

View File

@ -22,14 +22,14 @@ package org.elasticsearch.index.reindex;
import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse;
import org.elasticsearch.action.support.tasks.TasksRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* Java API support for changing the throttle on reindex tasks while they are running.
*/
public class RethrottleRequestBuilder extends TasksRequestBuilder<RethrottleRequest, ListTasksResponse, RethrottleRequestBuilder> {
public RethrottleRequestBuilder(ElasticsearchClient client,
ActionType<ListTasksResponse> action) {
public RethrottleRequestBuilder(OpenSearchClient client,
ActionType<ListTasksResponse> action) {
super(client, action, new RethrottleRequest());
}

View File

@ -19,7 +19,7 @@
package org.elasticsearch.action;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.unit.TimeValue;
import java.util.Objects;
@ -28,9 +28,9 @@ public abstract class ActionRequestBuilder<Request extends ActionRequest, Respon
protected final ActionType<Response> action;
protected final Request request;
protected final ElasticsearchClient client;
protected final OpenSearchClient client;
protected ActionRequestBuilder(ElasticsearchClient client, ActionType<Response> action, Request request) {
protected ActionRequestBuilder(OpenSearchClient client, ActionType<Response> action, Request request) {
Objects.requireNonNull(action, "action must not be null");
this.action = action;
this.request = request;

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.admin.cluster.allocation;
import org.elasticsearch.action.support.master.MasterNodeOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* Builder for requests to explain the allocation of a shard in the cluster
@ -30,7 +30,7 @@ public class ClusterAllocationExplainRequestBuilder
ClusterAllocationExplainResponse,
ClusterAllocationExplainRequestBuilder> {
public ClusterAllocationExplainRequestBuilder(ElasticsearchClient client, ClusterAllocationExplainAction action) {
public ClusterAllocationExplainRequestBuilder(OpenSearchClient client, ClusterAllocationExplainAction action) {
super(client, action, new ClusterAllocationExplainRequest());
}

View File

@ -22,7 +22,7 @@ package org.elasticsearch.action.admin.cluster.health;
import org.elasticsearch.action.support.ActiveShardCount;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.cluster.health.ClusterHealthStatus;
import org.elasticsearch.common.Priority;
import org.elasticsearch.common.unit.TimeValue;
@ -30,7 +30,7 @@ import org.elasticsearch.common.unit.TimeValue;
public class ClusterHealthRequestBuilder
extends MasterNodeReadOperationRequestBuilder<ClusterHealthRequest, ClusterHealthResponse, ClusterHealthRequestBuilder> {
public ClusterHealthRequestBuilder(ElasticsearchClient client, ClusterHealthAction action) {
public ClusterHealthRequestBuilder(OpenSearchClient client, ClusterHealthAction action) {
super(client, action, new ClusterHealthRequest());
}

View File

@ -20,13 +20,13 @@
package org.elasticsearch.action.admin.cluster.node.hotthreads;
import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.unit.TimeValue;
public class NodesHotThreadsRequestBuilder
extends NodesOperationRequestBuilder<NodesHotThreadsRequest, NodesHotThreadsResponse, NodesHotThreadsRequestBuilder> {
public NodesHotThreadsRequestBuilder(ElasticsearchClient client, NodesHotThreadsAction action) {
public NodesHotThreadsRequestBuilder(OpenSearchClient client, NodesHotThreadsAction action) {
super(client, action, new NodesHotThreadsRequest());
}

View File

@ -20,11 +20,11 @@
package org.elasticsearch.action.admin.cluster.node.info;
import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class NodesInfoRequestBuilder extends NodesOperationRequestBuilder<NodesInfoRequest, NodesInfoResponse, NodesInfoRequestBuilder> {
public NodesInfoRequestBuilder(ElasticsearchClient client, NodesInfoAction action) {
public NodesInfoRequestBuilder(OpenSearchClient client, NodesInfoAction action) {
super(client, action, new NodesInfoRequest());
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.admin.cluster.node.reload;
import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.settings.SecureString;
/**
@ -29,7 +29,7 @@ import org.elasticsearch.common.settings.SecureString;
public class NodesReloadSecureSettingsRequestBuilder extends NodesOperationRequestBuilder<NodesReloadSecureSettingsRequest,
NodesReloadSecureSettingsResponse, NodesReloadSecureSettingsRequestBuilder> {
public NodesReloadSecureSettingsRequestBuilder(ElasticsearchClient client, NodesReloadSecureSettingsAction action) {
public NodesReloadSecureSettingsRequestBuilder(OpenSearchClient client, NodesReloadSecureSettingsAction action) {
super(client, action, new NodesReloadSecureSettingsRequest());
}

View File

@ -21,12 +21,12 @@ package org.elasticsearch.action.admin.cluster.node.stats;
import org.elasticsearch.action.admin.indices.stats.CommonStatsFlags;
import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class NodesStatsRequestBuilder
extends NodesOperationRequestBuilder<NodesStatsRequest, NodesStatsResponse, NodesStatsRequestBuilder> {
public NodesStatsRequestBuilder(ElasticsearchClient client, NodesStatsAction action) {
public NodesStatsRequestBuilder(OpenSearchClient client, NodesStatsAction action) {
super(client, action, new NodesStatsRequest());
}

View File

@ -20,14 +20,14 @@
package org.elasticsearch.action.admin.cluster.node.tasks.cancel;
import org.elasticsearch.action.support.tasks.TasksRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* Builder for the request to cancel tasks running on the specified nodes
*/
public class CancelTasksRequestBuilder extends TasksRequestBuilder<CancelTasksRequest, CancelTasksResponse, CancelTasksRequestBuilder> {
public CancelTasksRequestBuilder(ElasticsearchClient client, CancelTasksAction action) {
public CancelTasksRequestBuilder(OpenSearchClient client, CancelTasksAction action) {
super(client, action, new CancelTasksRequest());
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.admin.cluster.node.tasks.get;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.tasks.TaskId;
@ -28,7 +28,7 @@ import org.elasticsearch.tasks.TaskId;
* Builder for the request to retrieve the list of tasks running on the specified nodes
*/
public class GetTaskRequestBuilder extends ActionRequestBuilder<GetTaskRequest, GetTaskResponse> {
public GetTaskRequestBuilder(ElasticsearchClient client, GetTaskAction action) {
public GetTaskRequestBuilder(OpenSearchClient client, GetTaskAction action) {
super(client, action, new GetTaskRequest());
}

View File

@ -20,14 +20,14 @@
package org.elasticsearch.action.admin.cluster.node.tasks.list;
import org.elasticsearch.action.support.tasks.TasksRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* Builder for the request to retrieve the list of tasks running on the specified nodes
*/
public class ListTasksRequestBuilder extends TasksRequestBuilder<ListTasksRequest, ListTasksResponse, ListTasksRequestBuilder> {
public ListTasksRequestBuilder(ElasticsearchClient client, ListTasksAction action) {
public ListTasksRequestBuilder(OpenSearchClient client, ListTasksAction action) {
super(client, action, new ListTasksRequest());
}

View File

@ -21,12 +21,12 @@ package org.elasticsearch.action.admin.cluster.node.usage;
import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class NodesUsageRequestBuilder
extends NodesOperationRequestBuilder<NodesUsageRequest, NodesUsageResponse, NodesUsageRequestBuilder> {
public NodesUsageRequestBuilder(ElasticsearchClient client, ActionType<NodesUsageResponse> action) {
public NodesUsageRequestBuilder(OpenSearchClient client, ActionType<NodesUsageResponse> action) {
super(client, action, new NodesUsageRequest());
}

View File

@ -20,11 +20,11 @@
package org.elasticsearch.action.admin.cluster.remote;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public final class RemoteInfoRequestBuilder extends ActionRequestBuilder<RemoteInfoRequest, RemoteInfoResponse> {
public RemoteInfoRequestBuilder(ElasticsearchClient client, RemoteInfoAction action) {
public RemoteInfoRequestBuilder(OpenSearchClient client, RemoteInfoAction action) {
super(client, action, new RemoteInfoRequest());
}
}

View File

@ -20,14 +20,14 @@ package org.elasticsearch.action.admin.cluster.repositories.cleanup;
import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.support.master.MasterNodeOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class CleanupRepositoryRequestBuilder extends MasterNodeOperationRequestBuilder<CleanupRepositoryRequest,
CleanupRepositoryResponse,
CleanupRepositoryRequestBuilder> {
public CleanupRepositoryRequestBuilder(ElasticsearchClient client, ActionType<CleanupRepositoryResponse> action,
String repository) {
public CleanupRepositoryRequestBuilder(OpenSearchClient client, ActionType<CleanupRepositoryResponse> action,
String repository) {
super(client, action, new CleanupRepositoryRequest(repository));
}

View File

@ -21,7 +21,7 @@ package org.elasticsearch.action.admin.cluster.repositories.delete;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* Builder for unregister repository request
@ -32,14 +32,14 @@ public class DeleteRepositoryRequestBuilder
/**
* Constructs unregister repository request builder
*/
public DeleteRepositoryRequestBuilder(ElasticsearchClient client, DeleteRepositoryAction action) {
public DeleteRepositoryRequestBuilder(OpenSearchClient client, DeleteRepositoryAction action) {
super(client, action, new DeleteRepositoryRequest());
}
/**
* Constructs unregister repository request builder with specified repository name
*/
public DeleteRepositoryRequestBuilder(ElasticsearchClient client, DeleteRepositoryAction action, String name) {
public DeleteRepositoryRequestBuilder(OpenSearchClient client, DeleteRepositoryAction action, String name) {
super(client, action, new DeleteRepositoryRequest(name));
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.admin.cluster.repositories.get;
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.util.ArrayUtils;
/**
@ -32,14 +32,14 @@ public class GetRepositoriesRequestBuilder
/**
* Creates new get repository request builder
*/
public GetRepositoriesRequestBuilder(ElasticsearchClient client, GetRepositoriesAction action) {
public GetRepositoriesRequestBuilder(OpenSearchClient client, GetRepositoriesAction action) {
super(client, action, new GetRepositoriesRequest());
}
/**
* Creates new get repository request builder
*/
public GetRepositoriesRequestBuilder(ElasticsearchClient client, GetRepositoriesAction action, String... repositories) {
public GetRepositoriesRequestBuilder(OpenSearchClient client, GetRepositoriesAction action, String... repositories) {
super(client, action, new GetRepositoriesRequest(repositories));
}

View File

@ -21,7 +21,7 @@ package org.elasticsearch.action.admin.cluster.repositories.put;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentType;
@ -36,14 +36,14 @@ public class PutRepositoryRequestBuilder
/**
* Constructs register repository request
*/
public PutRepositoryRequestBuilder(ElasticsearchClient client, PutRepositoryAction action) {
public PutRepositoryRequestBuilder(OpenSearchClient client, PutRepositoryAction action) {
super(client, action, new PutRepositoryRequest());
}
/**
* Constructs register repository request for the repository with a given name
*/
public PutRepositoryRequestBuilder(ElasticsearchClient client, PutRepositoryAction action, String name) {
public PutRepositoryRequestBuilder(OpenSearchClient client, PutRepositoryAction action, String name) {
super(client, action, new PutRepositoryRequest(name));
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.admin.cluster.repositories.verify;
import org.elasticsearch.action.support.master.MasterNodeOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* Builder for verify repository request
@ -31,14 +31,14 @@ public class VerifyRepositoryRequestBuilder
/**
* Constructs unregister repository request builder
*/
public VerifyRepositoryRequestBuilder(ElasticsearchClient client, VerifyRepositoryAction action) {
public VerifyRepositoryRequestBuilder(OpenSearchClient client, VerifyRepositoryAction action) {
super(client, action, new VerifyRepositoryRequest());
}
/**
* Constructs unregister repository request builder with specified repository name
*/
public VerifyRepositoryRequestBuilder(ElasticsearchClient client, VerifyRepositoryAction action, String name) {
public VerifyRepositoryRequestBuilder(OpenSearchClient client, VerifyRepositoryAction action, String name) {
super(client, action, new VerifyRepositoryRequest(name));
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.admin.cluster.reroute;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.cluster.routing.allocation.command.AllocationCommand;
/**
@ -28,7 +28,7 @@ import org.elasticsearch.cluster.routing.allocation.command.AllocationCommand;
*/
public class ClusterRerouteRequestBuilder
extends AcknowledgedRequestBuilder<ClusterRerouteRequest, ClusterRerouteResponse, ClusterRerouteRequestBuilder> {
public ClusterRerouteRequestBuilder(ElasticsearchClient client, ClusterRerouteAction action) {
public ClusterRerouteRequestBuilder(OpenSearchClient client, ClusterRerouteAction action) {
super(client, action, new ClusterRerouteRequest());
}
@ -67,4 +67,4 @@ public class ClusterRerouteRequestBuilder
request.setRetryFailed(retryFailed);
return this;
}
}
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.admin.cluster.settings;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentType;
@ -32,7 +32,7 @@ import java.util.Map;
public class ClusterUpdateSettingsRequestBuilder extends AcknowledgedRequestBuilder<ClusterUpdateSettingsRequest,
ClusterUpdateSettingsResponse, ClusterUpdateSettingsRequestBuilder> {
public ClusterUpdateSettingsRequestBuilder(ElasticsearchClient client, ClusterUpdateSettingsAction action) {
public ClusterUpdateSettingsRequestBuilder(OpenSearchClient client, ClusterUpdateSettingsAction action) {
super(client, action, new ClusterUpdateSettingsRequest());
}

View File

@ -21,12 +21,12 @@ package org.elasticsearch.action.admin.cluster.shards;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class ClusterSearchShardsRequestBuilder extends MasterNodeReadOperationRequestBuilder<ClusterSearchShardsRequest,
ClusterSearchShardsResponse, ClusterSearchShardsRequestBuilder> {
public ClusterSearchShardsRequestBuilder(ElasticsearchClient client, ClusterSearchShardsAction action) {
public ClusterSearchShardsRequestBuilder(OpenSearchClient client, ClusterSearchShardsAction action) {
super(client, action, new ClusterSearchShardsRequest());
}

View File

@ -23,18 +23,18 @@ import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.action.support.master.MasterNodeOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.Strings;
public class CloneSnapshotRequestBuilder extends MasterNodeOperationRequestBuilder<CloneSnapshotRequest, AcknowledgedResponse,
CloneSnapshotRequestBuilder> {
protected CloneSnapshotRequestBuilder(ElasticsearchClient client, ActionType<AcknowledgedResponse> action,
protected CloneSnapshotRequestBuilder(OpenSearchClient client, ActionType<AcknowledgedResponse> action,
CloneSnapshotRequest request) {
super(client, action, request);
}
public CloneSnapshotRequestBuilder(ElasticsearchClient client, ActionType<AcknowledgedResponse> action,
public CloneSnapshotRequestBuilder(OpenSearchClient client, ActionType<AcknowledgedResponse> action,
String repository, String source, String target) {
this(client, action, new CloneSnapshotRequest(repository, source, target, Strings.EMPTY_ARRAY));
}

View File

@ -21,7 +21,7 @@ package org.elasticsearch.action.admin.cluster.snapshots.create;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.MasterNodeOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentType;
@ -36,14 +36,14 @@ public class CreateSnapshotRequestBuilder extends MasterNodeOperationRequestBuil
/**
* Constructs a new create snapshot request builder
*/
public CreateSnapshotRequestBuilder(ElasticsearchClient client, CreateSnapshotAction action) {
public CreateSnapshotRequestBuilder(OpenSearchClient client, CreateSnapshotAction action) {
super(client, action, new CreateSnapshotRequest());
}
/**
* Constructs a new create snapshot request builder with specified repository and snapshot names
*/
public CreateSnapshotRequestBuilder(ElasticsearchClient client, CreateSnapshotAction action, String repository, String snapshot) {
public CreateSnapshotRequestBuilder(OpenSearchClient client, CreateSnapshotAction action, String repository, String snapshot) {
super(client, action, new CreateSnapshotRequest(repository, snapshot));
}

View File

@ -21,7 +21,7 @@ package org.elasticsearch.action.admin.cluster.snapshots.delete;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.action.support.master.MasterNodeOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* Delete snapshot request builder
@ -32,14 +32,14 @@ public class DeleteSnapshotRequestBuilder extends MasterNodeOperationRequestBuil
/**
* Constructs delete snapshot request builder
*/
public DeleteSnapshotRequestBuilder(ElasticsearchClient client, DeleteSnapshotAction action) {
public DeleteSnapshotRequestBuilder(OpenSearchClient client, DeleteSnapshotAction action) {
super(client, action, new DeleteSnapshotRequest());
}
/**
* Constructs delete snapshot request builder with specified repository and snapshot names
*/
public DeleteSnapshotRequestBuilder(ElasticsearchClient client, DeleteSnapshotAction action, String repository, String... snapshots) {
public DeleteSnapshotRequestBuilder(OpenSearchClient client, DeleteSnapshotAction action, String repository, String... snapshots) {
super(client, action, new DeleteSnapshotRequest(repository, snapshots));
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.admin.cluster.snapshots.get;
import org.elasticsearch.action.support.master.MasterNodeOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.util.ArrayUtils;
/**
@ -32,14 +32,14 @@ public class GetSnapshotsRequestBuilder extends MasterNodeOperationRequestBuilde
/**
* Constructs the new get snapshot request
*/
public GetSnapshotsRequestBuilder(ElasticsearchClient client, GetSnapshotsAction action) {
public GetSnapshotsRequestBuilder(OpenSearchClient client, GetSnapshotsAction action) {
super(client, action, new GetSnapshotsRequest());
}
/**
* Constructs the new get snapshot request with specified repository
*/
public GetSnapshotsRequestBuilder(ElasticsearchClient client, GetSnapshotsAction action, String repository) {
public GetSnapshotsRequestBuilder(OpenSearchClient client, GetSnapshotsAction action, String repository) {
super(client, action, new GetSnapshotsRequest(repository));
}

View File

@ -21,7 +21,7 @@ package org.elasticsearch.action.admin.cluster.snapshots.restore;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.MasterNodeOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentType;
@ -37,14 +37,14 @@ public class RestoreSnapshotRequestBuilder extends MasterNodeOperationRequestBui
/**
* Constructs new restore snapshot request builder
*/
public RestoreSnapshotRequestBuilder(ElasticsearchClient client, RestoreSnapshotAction action) {
public RestoreSnapshotRequestBuilder(OpenSearchClient client, RestoreSnapshotAction action) {
super(client, action, new RestoreSnapshotRequest());
}
/**
* Constructs new restore snapshot request builder with specified repository and snapshot names
*/
public RestoreSnapshotRequestBuilder(ElasticsearchClient client, RestoreSnapshotAction action, String repository, String name) {
public RestoreSnapshotRequestBuilder(OpenSearchClient client, RestoreSnapshotAction action, String repository, String name) {
super(client, action, new RestoreSnapshotRequest(repository, name));
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.admin.cluster.snapshots.status;
import org.elasticsearch.action.support.master.MasterNodeOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.util.ArrayUtils;
/**
@ -32,14 +32,14 @@ public class SnapshotsStatusRequestBuilder extends MasterNodeOperationRequestBui
/**
* Constructs the new snapshot status request
*/
public SnapshotsStatusRequestBuilder(ElasticsearchClient client, SnapshotsStatusAction action) {
public SnapshotsStatusRequestBuilder(OpenSearchClient client, SnapshotsStatusAction action) {
super(client, action, new SnapshotsStatusRequest());
}
/**
* Constructs the new snapshot status request with specified repository
*/
public SnapshotsStatusRequestBuilder(ElasticsearchClient client, SnapshotsStatusAction action, String repository) {
public SnapshotsStatusRequestBuilder(OpenSearchClient client, SnapshotsStatusAction action, String repository) {
super(client, action, new SnapshotsStatusRequest(repository));
}

View File

@ -21,13 +21,13 @@ package org.elasticsearch.action.admin.cluster.state;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.unit.TimeValue;
public class ClusterStateRequestBuilder extends MasterNodeReadOperationRequestBuilder<ClusterStateRequest,
ClusterStateResponse, ClusterStateRequestBuilder> {
public ClusterStateRequestBuilder(ElasticsearchClient client, ClusterStateAction action) {
public ClusterStateRequestBuilder(OpenSearchClient client, ClusterStateAction action) {
super(client, action, new ClusterStateRequest());
}

View File

@ -20,12 +20,12 @@
package org.elasticsearch.action.admin.cluster.stats;
import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class ClusterStatsRequestBuilder extends NodesOperationRequestBuilder<ClusterStatsRequest,
ClusterStatsResponse, ClusterStatsRequestBuilder> {
public ClusterStatsRequestBuilder(ElasticsearchClient client, ClusterStatsAction action) {
public ClusterStatsRequestBuilder(OpenSearchClient client, ClusterStatsAction action) {
super(client, action, new ClusterStatsRequest());
}
}

View File

@ -21,12 +21,12 @@ package org.elasticsearch.action.admin.cluster.storedscripts;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class DeleteStoredScriptRequestBuilder extends AcknowledgedRequestBuilder<DeleteStoredScriptRequest,
AcknowledgedResponse, DeleteStoredScriptRequestBuilder> {
public DeleteStoredScriptRequestBuilder(ElasticsearchClient client, DeleteStoredScriptAction action) {
public DeleteStoredScriptRequestBuilder(OpenSearchClient client, DeleteStoredScriptAction action) {
super(client, action, new DeleteStoredScriptRequest());
}

View File

@ -20,13 +20,13 @@
package org.elasticsearch.action.admin.cluster.storedscripts;
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class GetStoredScriptRequestBuilder extends MasterNodeReadOperationRequestBuilder<GetStoredScriptRequest,
GetStoredScriptResponse, GetStoredScriptRequestBuilder> {
public GetStoredScriptRequestBuilder(ElasticsearchClient client, GetStoredScriptAction action) {
public GetStoredScriptRequestBuilder(OpenSearchClient client, GetStoredScriptAction action) {
super(client, action, new GetStoredScriptRequest());
}

View File

@ -21,14 +21,14 @@ package org.elasticsearch.action.admin.cluster.storedscripts;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.bytes.BytesReference;
import org.elasticsearch.common.xcontent.XContentType;
public class PutStoredScriptRequestBuilder extends AcknowledgedRequestBuilder<PutStoredScriptRequest,
AcknowledgedResponse, PutStoredScriptRequestBuilder> {
public PutStoredScriptRequestBuilder(ElasticsearchClient client, PutStoredScriptAction action) {
public PutStoredScriptRequestBuilder(OpenSearchClient client, PutStoredScriptAction action) {
super(client, action, new PutStoredScriptRequest());
}

View File

@ -20,12 +20,12 @@
package org.elasticsearch.action.admin.cluster.tasks;
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class PendingClusterTasksRequestBuilder extends MasterNodeReadOperationRequestBuilder<PendingClusterTasksRequest,
PendingClusterTasksResponse, PendingClusterTasksRequestBuilder> {
public PendingClusterTasksRequestBuilder(ElasticsearchClient client, PendingClusterTasksAction action) {
public PendingClusterTasksRequestBuilder(OpenSearchClient client, PendingClusterTasksAction action) {
super(client, action, new PendingClusterTasksRequest());
}
}

View File

@ -22,7 +22,7 @@ package org.elasticsearch.action.admin.indices.alias;
import org.elasticsearch.action.admin.indices.alias.IndicesAliasesRequest.AliasActions;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.index.query.QueryBuilder;
import java.util.Map;
@ -33,7 +33,7 @@ import java.util.Map;
public class IndicesAliasesRequestBuilder
extends AcknowledgedRequestBuilder<IndicesAliasesRequest, AcknowledgedResponse, IndicesAliasesRequestBuilder> {
public IndicesAliasesRequestBuilder(ElasticsearchClient client, IndicesAliasesAction action) {
public IndicesAliasesRequestBuilder(OpenSearchClient client, IndicesAliasesAction action) {
super(client, action, new IndicesAliasesRequest());
}

View File

@ -20,11 +20,11 @@
package org.elasticsearch.action.admin.indices.alias.exists;
import org.elasticsearch.action.admin.indices.alias.get.BaseAliasesRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class AliasesExistRequestBuilder extends BaseAliasesRequestBuilder<AliasesExistResponse, AliasesExistRequestBuilder> {
public AliasesExistRequestBuilder(ElasticsearchClient client, AliasesExistAction action, String... aliases) {
public AliasesExistRequestBuilder(OpenSearchClient client, AliasesExistAction action, String... aliases) {
super(client, action, aliases);
}
}

View File

@ -23,14 +23,14 @@ import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.ActionResponse;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.util.ArrayUtils;
public abstract class BaseAliasesRequestBuilder<Response extends ActionResponse,
Builder extends BaseAliasesRequestBuilder<Response, Builder>>
extends MasterNodeReadOperationRequestBuilder<GetAliasesRequest, Response, Builder> {
public BaseAliasesRequestBuilder(ElasticsearchClient client, ActionType<Response> action, String... aliases) {
public BaseAliasesRequestBuilder(OpenSearchClient client, ActionType<Response> action, String... aliases) {
super(client, action, new GetAliasesRequest(aliases));
}

View File

@ -19,11 +19,11 @@
package org.elasticsearch.action.admin.indices.alias.get;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class GetAliasesRequestBuilder extends BaseAliasesRequestBuilder<GetAliasesResponse, GetAliasesRequestBuilder> {
public GetAliasesRequestBuilder(ElasticsearchClient client, GetAliasesAction action, String... aliases) {
public GetAliasesRequestBuilder(OpenSearchClient client, GetAliasesAction action, String... aliases) {
super(client, action, aliases);
}
}

View File

@ -19,18 +19,18 @@
package org.elasticsearch.action.admin.indices.analyze;
import org.elasticsearch.action.support.single.shard.SingleShardOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import java.util.Map;
public class AnalyzeRequestBuilder
extends SingleShardOperationRequestBuilder<AnalyzeAction.Request, AnalyzeAction.Response, AnalyzeRequestBuilder> {
public AnalyzeRequestBuilder(ElasticsearchClient client, AnalyzeAction action) {
public AnalyzeRequestBuilder(OpenSearchClient client, AnalyzeAction action) {
super(client, action, new AnalyzeAction.Request());
}
public AnalyzeRequestBuilder(ElasticsearchClient client, AnalyzeAction action, String index, String... text) {
public AnalyzeRequestBuilder(OpenSearchClient client, AnalyzeAction action, String index, String... text) {
super(client, action, new AnalyzeAction.Request(index).text(text));
}

View File

@ -20,12 +20,12 @@
package org.elasticsearch.action.admin.indices.cache.clear;
import org.elasticsearch.action.support.broadcast.BroadcastOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class ClearIndicesCacheRequestBuilder
extends BroadcastOperationRequestBuilder<ClearIndicesCacheRequest, ClearIndicesCacheResponse, ClearIndicesCacheRequestBuilder> {
public ClearIndicesCacheRequestBuilder(ElasticsearchClient client, ClearIndicesCacheAction action) {
public ClearIndicesCacheRequestBuilder(OpenSearchClient client, ClearIndicesCacheAction action) {
super(client, action, new ClearIndicesCacheRequest());
}

View File

@ -22,7 +22,7 @@ package org.elasticsearch.action.admin.indices.close;
import org.elasticsearch.action.support.ActiveShardCount;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* Builder for close index request
@ -30,11 +30,11 @@ import org.elasticsearch.client.ElasticsearchClient;
public class CloseIndexRequestBuilder
extends AcknowledgedRequestBuilder<CloseIndexRequest, CloseIndexResponse, CloseIndexRequestBuilder> {
public CloseIndexRequestBuilder(ElasticsearchClient client, CloseIndexAction action) {
public CloseIndexRequestBuilder(OpenSearchClient client, CloseIndexAction action) {
super(client, action, new CloseIndexRequest());
}
public CloseIndexRequestBuilder(ElasticsearchClient client, CloseIndexAction action, String... indices) {
public CloseIndexRequestBuilder(OpenSearchClient client, CloseIndexAction action, String... indices) {
super(client, action, new CloseIndexRequest(indices));
}

View File

@ -22,7 +22,7 @@ package org.elasticsearch.action.admin.indices.create;
import org.elasticsearch.action.admin.indices.alias.Alias;
import org.elasticsearch.action.support.ActiveShardCount;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.bytes.BytesReference;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.LoggingDeprecationHandler;
@ -37,11 +37,11 @@ import java.util.Map;
public class CreateIndexRequestBuilder
extends AcknowledgedRequestBuilder<CreateIndexRequest, CreateIndexResponse, CreateIndexRequestBuilder> {
public CreateIndexRequestBuilder(ElasticsearchClient client, CreateIndexAction action) {
public CreateIndexRequestBuilder(OpenSearchClient client, CreateIndexAction action) {
super(client, action, new CreateIndexRequest());
}
public CreateIndexRequestBuilder(ElasticsearchClient client, CreateIndexAction action, String index) {
public CreateIndexRequestBuilder(OpenSearchClient client, CreateIndexAction action, String index) {
super(client, action, new CreateIndexRequest(index));
}

View File

@ -22,12 +22,12 @@ package org.elasticsearch.action.admin.indices.delete;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class DeleteIndexRequestBuilder
extends AcknowledgedRequestBuilder<DeleteIndexRequest, AcknowledgedResponse, DeleteIndexRequestBuilder> {
public DeleteIndexRequestBuilder(ElasticsearchClient client, DeleteIndexAction action, String... indices) {
public DeleteIndexRequestBuilder(OpenSearchClient client, DeleteIndexAction action, String... indices) {
super(client, action, new DeleteIndexRequest(indices));
}

View File

@ -20,12 +20,12 @@
package org.elasticsearch.action.admin.indices.exists.indices;
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class IndicesExistsRequestBuilder
extends MasterNodeReadOperationRequestBuilder<IndicesExistsRequest, IndicesExistsResponse, IndicesExistsRequestBuilder> {
public IndicesExistsRequestBuilder(ElasticsearchClient client, IndicesExistsAction action, String... indices) {
public IndicesExistsRequestBuilder(OpenSearchClient client, IndicesExistsAction action, String... indices) {
super(client, action, new IndicesExistsRequest(indices));
}

View File

@ -20,7 +20,7 @@ package org.elasticsearch.action.admin.indices.exists.types;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.Strings;
/**
@ -33,11 +33,11 @@ public class TypesExistsRequestBuilder
/**
* @param indices What indices to check for types
*/
public TypesExistsRequestBuilder(ElasticsearchClient client, TypesExistsAction action, String... indices) {
public TypesExistsRequestBuilder(OpenSearchClient client, TypesExistsAction action, String... indices) {
super(client, action, new TypesExistsRequest(indices, Strings.EMPTY_ARRAY));
}
TypesExistsRequestBuilder(ElasticsearchClient client, TypesExistsAction action) {
TypesExistsRequestBuilder(OpenSearchClient client, TypesExistsAction action) {
super(client, action, new TypesExistsRequest());
}

View File

@ -20,11 +20,11 @@
package org.elasticsearch.action.admin.indices.flush;
import org.elasticsearch.action.support.broadcast.BroadcastOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class FlushRequestBuilder extends BroadcastOperationRequestBuilder<FlushRequest, FlushResponse, FlushRequestBuilder> {
public FlushRequestBuilder(ElasticsearchClient client, FlushAction action) {
public FlushRequestBuilder(OpenSearchClient client, FlushAction action) {
super(client, action, new FlushRequest());
}

View File

@ -21,11 +21,11 @@ package org.elasticsearch.action.admin.indices.flush;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class SyncedFlushRequestBuilder extends ActionRequestBuilder<SyncedFlushRequest, SyncedFlushResponse> {
public SyncedFlushRequestBuilder(ElasticsearchClient client, SyncedFlushAction action) {
public SyncedFlushRequestBuilder(OpenSearchClient client, SyncedFlushAction action) {
super(client, action, new SyncedFlushRequest());
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.admin.indices.forcemerge;
import org.elasticsearch.action.support.broadcast.BroadcastOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* A request to force merge one or more indices. In order to force merge all
@ -32,7 +32,7 @@ import org.elasticsearch.client.ElasticsearchClient;
public class ForceMergeRequestBuilder
extends BroadcastOperationRequestBuilder<ForceMergeRequest, ForceMergeResponse, ForceMergeRequestBuilder> {
public ForceMergeRequestBuilder(ElasticsearchClient client, ForceMergeAction action) {
public ForceMergeRequestBuilder(OpenSearchClient client, ForceMergeAction action) {
super(client, action, new ForceMergeRequest());
}

View File

@ -21,11 +21,11 @@ package org.elasticsearch.action.admin.indices.get;
import org.elasticsearch.action.admin.indices.get.GetIndexRequest.Feature;
import org.elasticsearch.action.support.master.info.ClusterInfoRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class GetIndexRequestBuilder extends ClusterInfoRequestBuilder<GetIndexRequest, GetIndexResponse, GetIndexRequestBuilder> {
public GetIndexRequestBuilder(ElasticsearchClient client, GetIndexAction action, String... indices) {
public GetIndexRequestBuilder(OpenSearchClient client, GetIndexAction action, String... indices) {
super(client, action, new GetIndexRequest().indices(indices));
}

View File

@ -21,14 +21,14 @@ package org.elasticsearch.action.admin.indices.mapping.get;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.util.ArrayUtils;
/** A helper class to build {@link GetFieldMappingsRequest} objects */
public class GetFieldMappingsRequestBuilder
extends ActionRequestBuilder<GetFieldMappingsRequest, GetFieldMappingsResponse> {
public GetFieldMappingsRequestBuilder(ElasticsearchClient client, GetFieldMappingsAction action, String... indices) {
public GetFieldMappingsRequestBuilder(OpenSearchClient client, GetFieldMappingsAction action, String... indices) {
super(client, action, new GetFieldMappingsRequest().indices(indices));
}

View File

@ -20,12 +20,12 @@
package org.elasticsearch.action.admin.indices.mapping.get;
import org.elasticsearch.action.support.master.info.ClusterInfoRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class GetMappingsRequestBuilder
extends ClusterInfoRequestBuilder<GetMappingsRequest, GetMappingsResponse, GetMappingsRequestBuilder> {
public GetMappingsRequestBuilder(ElasticsearchClient client, GetMappingsAction action, String... indices) {
public GetMappingsRequestBuilder(OpenSearchClient client, GetMappingsAction action, String... indices) {
super(client, action, new GetMappingsRequest().indices(indices));
}
}

View File

@ -22,7 +22,7 @@ package org.elasticsearch.action.admin.indices.mapping.put;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.Index;
@ -35,7 +35,7 @@ import java.util.Map;
public class PutMappingRequestBuilder
extends AcknowledgedRequestBuilder<PutMappingRequest, AcknowledgedResponse, PutMappingRequestBuilder> {
public PutMappingRequestBuilder(ElasticsearchClient client, PutMappingAction action) {
public PutMappingRequestBuilder(OpenSearchClient client, PutMappingAction action) {
super(client, action, new PutMappingRequest());
}

View File

@ -22,18 +22,18 @@ package org.elasticsearch.action.admin.indices.open;
import org.elasticsearch.action.support.ActiveShardCount;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* Builder for for open index request
*/
public class OpenIndexRequestBuilder extends AcknowledgedRequestBuilder<OpenIndexRequest, OpenIndexResponse, OpenIndexRequestBuilder> {
public OpenIndexRequestBuilder(ElasticsearchClient client, OpenIndexAction action) {
public OpenIndexRequestBuilder(OpenSearchClient client, OpenIndexAction action) {
super(client, action, new OpenIndexRequest());
}
public OpenIndexRequestBuilder(ElasticsearchClient client, OpenIndexAction action, String... indices) {
public OpenIndexRequestBuilder(OpenSearchClient client, OpenIndexAction action, String... indices) {
super(client, action, new OpenIndexRequest(indices));
}

View File

@ -21,7 +21,7 @@ package org.elasticsearch.action.admin.indices.readonly;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.cluster.metadata.IndexMetadata.APIBlock;
/**
@ -30,7 +30,7 @@ import org.elasticsearch.cluster.metadata.IndexMetadata.APIBlock;
public class AddIndexBlockRequestBuilder
extends AcknowledgedRequestBuilder<AddIndexBlockRequest, AddIndexBlockResponse, AddIndexBlockRequestBuilder> {
public AddIndexBlockRequestBuilder(ElasticsearchClient client, AddIndexBlockAction action, APIBlock block, String... indices) {
public AddIndexBlockRequestBuilder(OpenSearchClient client, AddIndexBlockAction action, APIBlock block, String... indices) {
super(client, action, new AddIndexBlockRequest(block, indices));
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.admin.indices.recovery;
import org.elasticsearch.action.support.broadcast.BroadcastOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* Recovery information request builder.
@ -30,7 +30,7 @@ public class RecoveryRequestBuilder extends BroadcastOperationRequestBuilder<Rec
/**
* Constructs a new recovery information request builder.
*/
public RecoveryRequestBuilder(ElasticsearchClient client, RecoveryAction action) {
public RecoveryRequestBuilder(OpenSearchClient client, RecoveryAction action) {
super(client, action, new RecoveryRequest());
}
@ -43,4 +43,4 @@ public class RecoveryRequestBuilder extends BroadcastOperationRequestBuilder<Rec
request.activeOnly(activeOnly);
return this;
}
}
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.admin.indices.refresh;
import org.elasticsearch.action.support.broadcast.BroadcastOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* A refresh request making all operations performed since the last refresh available for search. The (near) real-time
@ -29,7 +29,7 @@ import org.elasticsearch.client.ElasticsearchClient;
*/
public class RefreshRequestBuilder extends BroadcastOperationRequestBuilder<RefreshRequest, RefreshResponse, RefreshRequestBuilder> {
public RefreshRequestBuilder(ElasticsearchClient client, RefreshAction action) {
public RefreshRequestBuilder(OpenSearchClient client, RefreshAction action) {
super(client, action, new RefreshRequest());
}
}

View File

@ -21,7 +21,7 @@ package org.elasticsearch.action.admin.indices.rollover;
import org.elasticsearch.action.admin.indices.alias.Alias;
import org.elasticsearch.action.support.ActiveShardCount;
import org.elasticsearch.action.support.master.MasterNodeOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.unit.TimeValue;
@ -30,7 +30,7 @@ import org.elasticsearch.common.xcontent.XContentType;
public class RolloverRequestBuilder extends MasterNodeOperationRequestBuilder<RolloverRequest, RolloverResponse,
RolloverRequestBuilder> {
public RolloverRequestBuilder(ElasticsearchClient client, RolloverAction action) {
public RolloverRequestBuilder(OpenSearchClient client, RolloverAction action) {
super(client, action, new RolloverRequest());
}

View File

@ -20,12 +20,12 @@
package org.elasticsearch.action.admin.indices.segments;
import org.elasticsearch.action.support.broadcast.BroadcastOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class IndicesSegmentsRequestBuilder
extends BroadcastOperationRequestBuilder<IndicesSegmentsRequest, IndicesSegmentResponse, IndicesSegmentsRequestBuilder> {
public IndicesSegmentsRequestBuilder(ElasticsearchClient client, IndicesSegmentsAction action) {
public IndicesSegmentsRequestBuilder(OpenSearchClient client, IndicesSegmentsAction action) {
super(client, action, new IndicesSegmentsRequest());
}

View File

@ -21,13 +21,13 @@ package org.elasticsearch.action.admin.indices.settings.get;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.util.ArrayUtils;
public class GetSettingsRequestBuilder
extends MasterNodeReadOperationRequestBuilder<GetSettingsRequest, GetSettingsResponse, GetSettingsRequestBuilder> {
public GetSettingsRequestBuilder(ElasticsearchClient client, GetSettingsAction action, String... indices) {
public GetSettingsRequestBuilder(OpenSearchClient client, GetSettingsAction action, String... indices) {
super(client, action, new GetSettingsRequest().indices(indices));
}

View File

@ -22,7 +22,7 @@ package org.elasticsearch.action.admin.indices.settings.put;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentType;
@ -34,7 +34,7 @@ import java.util.Map;
public class UpdateSettingsRequestBuilder
extends AcknowledgedRequestBuilder<UpdateSettingsRequest, AcknowledgedResponse, UpdateSettingsRequestBuilder> {
public UpdateSettingsRequestBuilder(ElasticsearchClient client, UpdateSettingsAction action, String... indices) {
public UpdateSettingsRequestBuilder(OpenSearchClient client, UpdateSettingsAction action, String... indices) {
super(client, action, new UpdateSettingsRequest(indices));
}

View File

@ -22,7 +22,7 @@ package org.elasticsearch.action.admin.indices.shards;
import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.cluster.health.ClusterHealthStatus;
/**
@ -33,7 +33,7 @@ public class IndicesShardStoreRequestBuilder extends MasterNodeReadOperationRequ
IndicesShardStoresResponse,
IndicesShardStoreRequestBuilder> {
public IndicesShardStoreRequestBuilder(ElasticsearchClient client, ActionType<IndicesShardStoresResponse> action, String... indices) {
public IndicesShardStoreRequestBuilder(OpenSearchClient client, ActionType<IndicesShardStoresResponse> action, String... indices) {
super(client, action, new IndicesShardStoresRequest(indices));
}

View File

@ -22,12 +22,12 @@ import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
import org.elasticsearch.action.support.ActiveShardCount;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.settings.Settings;
public class ResizeRequestBuilder extends AcknowledgedRequestBuilder<ResizeRequest, ResizeResponse,
ResizeRequestBuilder> {
public ResizeRequestBuilder(ElasticsearchClient client, ActionType<ResizeResponse> action) {
public ResizeRequestBuilder(OpenSearchClient client, ActionType<ResizeResponse> action) {
super(client, action, new ResizeRequest());
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.admin.indices.stats;
import org.elasticsearch.action.support.broadcast.BroadcastOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* A request to get indices level stats. Allow to enable different stats to be returned.
@ -34,7 +34,7 @@ import org.elasticsearch.client.ElasticsearchClient;
public class IndicesStatsRequestBuilder
extends BroadcastOperationRequestBuilder<IndicesStatsRequest, IndicesStatsResponse, IndicesStatsRequestBuilder> {
public IndicesStatsRequestBuilder(ElasticsearchClient client, IndicesStatsAction action) {
public IndicesStatsRequestBuilder(OpenSearchClient client, IndicesStatsAction action) {
super(client, action, new IndicesStatsRequest());
}

View File

@ -20,16 +20,16 @@ package org.elasticsearch.action.admin.indices.template.delete;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.action.support.master.MasterNodeOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class DeleteIndexTemplateRequestBuilder
extends MasterNodeOperationRequestBuilder<DeleteIndexTemplateRequest, AcknowledgedResponse, DeleteIndexTemplateRequestBuilder> {
public DeleteIndexTemplateRequestBuilder(ElasticsearchClient client, DeleteIndexTemplateAction action) {
public DeleteIndexTemplateRequestBuilder(OpenSearchClient client, DeleteIndexTemplateAction action) {
super(client, action, new DeleteIndexTemplateRequest());
}
public DeleteIndexTemplateRequestBuilder(ElasticsearchClient client, DeleteIndexTemplateAction action, String name) {
public DeleteIndexTemplateRequestBuilder(OpenSearchClient client, DeleteIndexTemplateAction action, String name) {
super(client, action, new DeleteIndexTemplateRequest(name));
}

View File

@ -19,18 +19,18 @@
package org.elasticsearch.action.admin.indices.template.get;
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class GetIndexTemplatesRequestBuilder extends MasterNodeReadOperationRequestBuilder<
GetIndexTemplatesRequest,
GetIndexTemplatesResponse,
GetIndexTemplatesRequestBuilder> {
public GetIndexTemplatesRequestBuilder(ElasticsearchClient client, GetIndexTemplatesAction action) {
public GetIndexTemplatesRequestBuilder(OpenSearchClient client, GetIndexTemplatesAction action) {
super(client, action, new GetIndexTemplatesRequest());
}
public GetIndexTemplatesRequestBuilder(ElasticsearchClient client, GetIndexTemplatesAction action, String... names) {
public GetIndexTemplatesRequestBuilder(OpenSearchClient client, GetIndexTemplatesAction action, String... names) {
super(client, action, new GetIndexTemplatesRequest(names));
}
}

View File

@ -21,7 +21,7 @@ package org.elasticsearch.action.admin.indices.template.put;
import org.elasticsearch.action.admin.indices.alias.Alias;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.action.support.master.MasterNodeOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.bytes.BytesReference;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentBuilder;
@ -33,11 +33,11 @@ import java.util.Map;
public class PutIndexTemplateRequestBuilder
extends MasterNodeOperationRequestBuilder<PutIndexTemplateRequest, AcknowledgedResponse, PutIndexTemplateRequestBuilder> {
public PutIndexTemplateRequestBuilder(ElasticsearchClient client, PutIndexTemplateAction action) {
public PutIndexTemplateRequestBuilder(OpenSearchClient client, PutIndexTemplateAction action) {
super(client, action, new PutIndexTemplateRequest());
}
public PutIndexTemplateRequestBuilder(ElasticsearchClient client, PutIndexTemplateAction action, String name) {
public PutIndexTemplateRequestBuilder(OpenSearchClient client, PutIndexTemplateAction action, String name) {
super(client, action, new PutIndexTemplateRequest(name));
}

View File

@ -20,12 +20,12 @@
package org.elasticsearch.action.admin.indices.upgrade.get;
import org.elasticsearch.action.support.broadcast.BroadcastOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class UpgradeStatusRequestBuilder
extends BroadcastOperationRequestBuilder<UpgradeStatusRequest, UpgradeStatusResponse, UpgradeStatusRequestBuilder> {
public UpgradeStatusRequestBuilder(ElasticsearchClient client, UpgradeStatusAction action) {
public UpgradeStatusRequestBuilder(OpenSearchClient client, UpgradeStatusAction action) {
super(client, action, new UpgradeStatusRequest());
}
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.admin.indices.upgrade.post;
import org.elasticsearch.action.support.broadcast.BroadcastOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* A request to upgrade one or more indices. In order to optimize on all the indices, pass an empty array or
@ -28,7 +28,7 @@ import org.elasticsearch.client.ElasticsearchClient;
*/
public class UpgradeRequestBuilder extends BroadcastOperationRequestBuilder<UpgradeRequest, UpgradeResponse, UpgradeRequestBuilder> {
public UpgradeRequestBuilder(ElasticsearchClient client, UpgradeAction action) {
public UpgradeRequestBuilder(OpenSearchClient client, UpgradeAction action) {
super(client, action, new UpgradeRequest());
}

View File

@ -22,7 +22,7 @@ package org.elasticsearch.action.admin.indices.upgrade.post;
import org.elasticsearch.Version;
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.collect.Tuple;
import java.util.Map;
@ -33,7 +33,7 @@ import java.util.Map;
public class UpgradeSettingsRequestBuilder
extends AcknowledgedRequestBuilder<UpgradeSettingsRequest, AcknowledgedResponse, UpgradeSettingsRequestBuilder> {
public UpgradeSettingsRequestBuilder(ElasticsearchClient client, UpgradeSettingsAction action) {
public UpgradeSettingsRequestBuilder(OpenSearchClient client, UpgradeSettingsAction action) {
super(client, action, new UpgradeSettingsRequest());
}

View File

@ -20,13 +20,13 @@
package org.elasticsearch.action.admin.indices.validate.query;
import org.elasticsearch.action.support.broadcast.BroadcastOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.index.query.QueryBuilder;
public class ValidateQueryRequestBuilder
extends BroadcastOperationRequestBuilder<ValidateQueryRequest, ValidateQueryResponse, ValidateQueryRequestBuilder> {
public ValidateQueryRequestBuilder(ElasticsearchClient client, ValidateQueryAction action) {
public ValidateQueryRequestBuilder(OpenSearchClient client, ValidateQueryAction action) {
super(client, action, new ValidateQueryRequest());
}

View File

@ -29,7 +29,7 @@ import org.elasticsearch.action.support.WriteRequestBuilder;
import org.elasticsearch.action.support.replication.ReplicationRequest;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.xcontent.XContentType;
@ -43,18 +43,18 @@ public class BulkRequestBuilder extends ActionRequestBuilder<BulkRequest, BulkRe
implements WriteRequestBuilder<BulkRequestBuilder> {
/**
* @deprecated use {@link #BulkRequestBuilder(ElasticsearchClient, BulkAction, String)} instead
* @deprecated use {@link #BulkRequestBuilder(OpenSearchClient, BulkAction, String)} instead
*/
@Deprecated
public BulkRequestBuilder(ElasticsearchClient client, BulkAction action, @Nullable String globalIndex, @Nullable String globalType) {
public BulkRequestBuilder(OpenSearchClient client, BulkAction action, @Nullable String globalIndex, @Nullable String globalType) {
super(client, action, new BulkRequest(globalIndex, globalType));
}
public BulkRequestBuilder(ElasticsearchClient client, BulkAction action, @Nullable String globalIndex) {
public BulkRequestBuilder(OpenSearchClient client, BulkAction action, @Nullable String globalIndex) {
super(client, action, new BulkRequest(globalIndex));
}
public BulkRequestBuilder(ElasticsearchClient client, BulkAction action) {
public BulkRequestBuilder(OpenSearchClient client, BulkAction action) {
super(client, action, new BulkRequest());
}
@ -121,7 +121,7 @@ public class BulkRequestBuilder extends ActionRequestBuilder<BulkRequest, BulkRe
* Adds a framed data in binary format
* @deprecated use {@link #add(byte[], int, int, String, XContentType)} instead
*/
@Deprecated
@Deprecated
public BulkRequestBuilder add(byte[] data, int from, int length, @Nullable String defaultIndex, @Nullable String defaultType,
XContentType xContentType) throws Exception {
request.add(data, from, length, defaultIndex, defaultType, xContentType);
@ -135,7 +135,7 @@ public class BulkRequestBuilder extends ActionRequestBuilder<BulkRequest, BulkRe
XContentType xContentType) throws Exception {
request.add(data, from, length, defaultIndex, MapperService.SINGLE_MAPPING_NAME, xContentType);
return this;
}
}
/**
* Sets the number of shard copies that must be active before proceeding with the write.

View File

@ -21,7 +21,7 @@ package org.elasticsearch.action.delete;
import org.elasticsearch.action.support.WriteRequestBuilder;
import org.elasticsearch.action.support.replication.ReplicationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.index.VersionType;
@ -31,11 +31,11 @@ import org.elasticsearch.index.VersionType;
public class DeleteRequestBuilder extends ReplicationRequestBuilder<DeleteRequest, DeleteResponse, DeleteRequestBuilder>
implements WriteRequestBuilder<DeleteRequestBuilder> {
public DeleteRequestBuilder(ElasticsearchClient client, DeleteAction action) {
public DeleteRequestBuilder(OpenSearchClient client, DeleteAction action) {
super(client, action, new DeleteRequest());
}
public DeleteRequestBuilder(ElasticsearchClient client, DeleteAction action, @Nullable String index) {
public DeleteRequestBuilder(OpenSearchClient client, DeleteAction action, @Nullable String index) {
super(client, action, new DeleteRequest(index));
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.explain;
import org.elasticsearch.action.support.single.shard.SingleShardOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.Strings;
import org.elasticsearch.index.query.QueryBuilder;
@ -31,11 +31,11 @@ import org.elasticsearch.search.fetch.subphase.FetchSourceContext;
*/
public class ExplainRequestBuilder extends SingleShardOperationRequestBuilder<ExplainRequest, ExplainResponse, ExplainRequestBuilder> {
ExplainRequestBuilder(ElasticsearchClient client, ExplainAction action) {
ExplainRequestBuilder(OpenSearchClient client, ExplainAction action) {
super(client, action, new ExplainRequest());
}
public ExplainRequestBuilder(ElasticsearchClient client, ExplainAction action, String index, String type, String id) {
public ExplainRequestBuilder(OpenSearchClient client, ExplainAction action, String index, String type, String id) {
super(client, action, new ExplainRequest().index(index).type(type).id(id));
}

View File

@ -20,11 +20,11 @@
package org.elasticsearch.action.fieldcaps;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.index.query.QueryBuilder;
public class FieldCapabilitiesRequestBuilder extends ActionRequestBuilder<FieldCapabilitiesRequest, FieldCapabilitiesResponse> {
public FieldCapabilitiesRequestBuilder(ElasticsearchClient client,
public FieldCapabilitiesRequestBuilder(OpenSearchClient client,
FieldCapabilitiesAction action,
String... indices) {
super(client, action, new FieldCapabilitiesRequest().indices(indices));

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.get;
import org.elasticsearch.action.support.single.shard.SingleShardOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.Strings;
import org.elasticsearch.index.VersionType;
@ -31,11 +31,11 @@ import org.elasticsearch.search.fetch.subphase.FetchSourceContext;
*/
public class GetRequestBuilder extends SingleShardOperationRequestBuilder<GetRequest, GetResponse, GetRequestBuilder> {
public GetRequestBuilder(ElasticsearchClient client, GetAction action) {
public GetRequestBuilder(OpenSearchClient client, GetAction action) {
super(client, action, new GetRequest());
}
public GetRequestBuilder(ElasticsearchClient client, GetAction action, @Nullable String index) {
public GetRequestBuilder(OpenSearchClient client, GetAction action, @Nullable String index) {
super(client, action, new GetRequest(index));
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.get;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.Nullable;
/**
@ -28,7 +28,7 @@ import org.elasticsearch.common.Nullable;
*/
public class MultiGetRequestBuilder extends ActionRequestBuilder<MultiGetRequest, MultiGetResponse> {
public MultiGetRequestBuilder(ElasticsearchClient client, MultiGetAction action) {
public MultiGetRequestBuilder(OpenSearchClient client, MultiGetAction action) {
super(client, action, new MultiGetRequest());
}

View File

@ -22,7 +22,7 @@ package org.elasticsearch.action.index;
import org.elasticsearch.action.DocWriteRequest;
import org.elasticsearch.action.support.WriteRequestBuilder;
import org.elasticsearch.action.support.replication.ReplicationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.bytes.BytesReference;
import org.elasticsearch.common.xcontent.XContentBuilder;
@ -37,11 +37,11 @@ import java.util.Map;
public class IndexRequestBuilder extends ReplicationRequestBuilder<IndexRequest, IndexResponse, IndexRequestBuilder>
implements WriteRequestBuilder<IndexRequestBuilder> {
public IndexRequestBuilder(ElasticsearchClient client, IndexAction action) {
public IndexRequestBuilder(OpenSearchClient client, IndexAction action) {
super(client, action, new IndexRequest());
}
public IndexRequestBuilder(ElasticsearchClient client, IndexAction action, @Nullable String index) {
public IndexRequestBuilder(OpenSearchClient client, IndexAction action, @Nullable String index) {
super(client, action, new IndexRequest(index));
}

View File

@ -21,15 +21,15 @@ package org.elasticsearch.action.ingest;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class DeletePipelineRequestBuilder extends ActionRequestBuilder<DeletePipelineRequest, AcknowledgedResponse> {
public DeletePipelineRequestBuilder(ElasticsearchClient client, DeletePipelineAction action) {
public DeletePipelineRequestBuilder(OpenSearchClient client, DeletePipelineAction action) {
super(client, action, new DeletePipelineRequest());
}
public DeletePipelineRequestBuilder(ElasticsearchClient client, DeletePipelineAction action, String id) {
public DeletePipelineRequestBuilder(OpenSearchClient client, DeletePipelineAction action, String id) {
super(client, action, new DeletePipelineRequest(id));
}

View File

@ -20,16 +20,16 @@
package org.elasticsearch.action.ingest;
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class GetPipelineRequestBuilder
extends MasterNodeReadOperationRequestBuilder<GetPipelineRequest, GetPipelineResponse, GetPipelineRequestBuilder> {
public GetPipelineRequestBuilder(ElasticsearchClient client, GetPipelineAction action) {
public GetPipelineRequestBuilder(OpenSearchClient client, GetPipelineAction action) {
super(client, action, new GetPipelineRequest());
}
public GetPipelineRequestBuilder(ElasticsearchClient client, GetPipelineAction action, String[] ids) {
public GetPipelineRequestBuilder(OpenSearchClient client, GetPipelineAction action, String[] ids) {
super(client, action, new GetPipelineRequest(ids));
}

View File

@ -21,17 +21,17 @@ package org.elasticsearch.action.ingest;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.bytes.BytesReference;
import org.elasticsearch.common.xcontent.XContentType;
public class PutPipelineRequestBuilder extends ActionRequestBuilder<PutPipelineRequest, AcknowledgedResponse> {
public PutPipelineRequestBuilder(ElasticsearchClient client, PutPipelineAction action) {
public PutPipelineRequestBuilder(OpenSearchClient client, PutPipelineAction action) {
super(client, action, new PutPipelineRequest());
}
public PutPipelineRequestBuilder(ElasticsearchClient client, PutPipelineAction action, String id, BytesReference source,
public PutPipelineRequestBuilder(OpenSearchClient client, PutPipelineAction action, String id, BytesReference source,
XContentType xContentType) {
super(client, action, new PutPipelineRequest(id, source, xContentType));
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.ingest;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.bytes.BytesReference;
import org.elasticsearch.common.xcontent.XContentType;
@ -29,14 +29,14 @@ public class SimulatePipelineRequestBuilder extends ActionRequestBuilder<Simulat
/**
* Create a new builder for {@link SimulatePipelineRequest}s
*/
public SimulatePipelineRequestBuilder(ElasticsearchClient client, SimulatePipelineAction action) {
public SimulatePipelineRequestBuilder(OpenSearchClient client, SimulatePipelineAction action) {
super(client, action, new SimulatePipelineRequest());
}
/**
* Create a new builder for {@link SimulatePipelineRequest}s
*/
public SimulatePipelineRequestBuilder(ElasticsearchClient client, SimulatePipelineAction action, BytesReference source,
public SimulatePipelineRequestBuilder(OpenSearchClient client, SimulatePipelineAction action, BytesReference source,
XContentType xContentType) {
super(client, action, new SimulatePipelineRequest(source, xContentType));
}

View File

@ -20,11 +20,11 @@
package org.elasticsearch.action.main;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public class MainRequestBuilder extends ActionRequestBuilder<MainRequest, MainResponse> {
public MainRequestBuilder(ElasticsearchClient client, MainAction action) {
public MainRequestBuilder(OpenSearchClient client, MainAction action) {
super(client, action, new MainRequest());
}
}

View File

@ -20,13 +20,13 @@
package org.elasticsearch.action.search;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import java.util.List;
public class ClearScrollRequestBuilder extends ActionRequestBuilder<ClearScrollRequest, ClearScrollResponse> {
public ClearScrollRequestBuilder(ElasticsearchClient client, ClearScrollAction action) {
public ClearScrollRequestBuilder(OpenSearchClient client, ClearScrollAction action) {
super(client, action, new ClearScrollRequest());
}

View File

@ -21,7 +21,7 @@ package org.elasticsearch.action.search;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* A request builder for multiple search requests.
@ -29,7 +29,7 @@ import org.elasticsearch.client.ElasticsearchClient;
public class MultiSearchRequestBuilder extends ActionRequestBuilder<MultiSearchRequest, MultiSearchResponse> {
public MultiSearchRequestBuilder(ElasticsearchClient client, MultiSearchAction action) {
public MultiSearchRequestBuilder(OpenSearchClient client, MultiSearchAction action) {
super(client, action, new MultiSearchRequest());
}

View File

@ -21,7 +21,7 @@ package org.elasticsearch.action.search;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.index.query.QueryBuilder;
@ -47,7 +47,7 @@ import java.util.List;
*/
public class SearchRequestBuilder extends ActionRequestBuilder<SearchRequest, SearchResponse> {
public SearchRequestBuilder(ElasticsearchClient client, SearchAction action) {
public SearchRequestBuilder(OpenSearchClient client, SearchAction action) {
super(client, action, new SearchRequest());
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.search;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.search.Scroll;
@ -29,11 +29,11 @@ import org.elasticsearch.search.Scroll;
*/
public class SearchScrollRequestBuilder extends ActionRequestBuilder<SearchScrollRequest, SearchResponse> {
public SearchScrollRequestBuilder(ElasticsearchClient client, SearchScrollAction action) {
public SearchScrollRequestBuilder(OpenSearchClient client, SearchScrollAction action) {
super(client, action, new SearchScrollRequest());
}
public SearchScrollRequestBuilder(ElasticsearchClient client, SearchScrollAction action, String scrollId) {
public SearchScrollRequestBuilder(OpenSearchClient client, SearchScrollAction action, String scrollId) {
super(client, action, new SearchScrollRequest(scrollId));
}

View File

@ -22,7 +22,7 @@ package org.elasticsearch.action.support.broadcast;
import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public abstract class BroadcastOperationRequestBuilder<
Request extends BroadcastRequest<Request>,
@ -30,7 +30,7 @@ public abstract class BroadcastOperationRequestBuilder<
RequestBuilder extends BroadcastOperationRequestBuilder<Request, Response, RequestBuilder>
> extends ActionRequestBuilder<Request, Response> {
protected BroadcastOperationRequestBuilder(ElasticsearchClient client, ActionType<Response> action, Request request) {
protected BroadcastOperationRequestBuilder(OpenSearchClient client, ActionType<Response> action, Request request) {
super(client, action, request);
}

View File

@ -19,7 +19,7 @@
package org.elasticsearch.action.support.master;
import org.elasticsearch.action.ActionType;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.unit.TimeValue;
/**
@ -29,7 +29,7 @@ public abstract class AcknowledgedRequestBuilder<Request extends AcknowledgedReq
RequestBuilder extends AcknowledgedRequestBuilder<Request, Response, RequestBuilder>>
extends MasterNodeOperationRequestBuilder<Request, Response, RequestBuilder> {
protected AcknowledgedRequestBuilder(ElasticsearchClient client, ActionType<Response> action, Request request) {
protected AcknowledgedRequestBuilder(OpenSearchClient client, ActionType<Response> action, Request request) {
super(client, action, request);
}

View File

@ -22,7 +22,7 @@ package org.elasticsearch.action.support.master;
import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.action.ActionResponse;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.unit.TimeValue;
/**
@ -32,7 +32,7 @@ public abstract class MasterNodeOperationRequestBuilder<Request extends MasterNo
RequestBuilder extends MasterNodeOperationRequestBuilder<Request, Response, RequestBuilder>>
extends ActionRequestBuilder<Request, Response> {
protected MasterNodeOperationRequestBuilder(ElasticsearchClient client, ActionType<Response> action, Request request) {
protected MasterNodeOperationRequestBuilder(OpenSearchClient client, ActionType<Response> action, Request request) {
super(client, action, request);
}

View File

@ -21,7 +21,7 @@ package org.elasticsearch.action.support.master;
import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.ActionResponse;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
/**
* Base request builder for master node read operations that can be executed on the local node as well
@ -30,7 +30,7 @@ public abstract class MasterNodeReadOperationRequestBuilder<Request extends Mast
RequestBuilder extends MasterNodeReadOperationRequestBuilder<Request, Response, RequestBuilder>>
extends MasterNodeOperationRequestBuilder<Request, Response, RequestBuilder> {
protected MasterNodeReadOperationRequestBuilder(ElasticsearchClient client, ActionType<Response> action, Request request) {
protected MasterNodeReadOperationRequestBuilder(OpenSearchClient client, ActionType<Response> action, Request request) {
super(client, action, request);
}

View File

@ -22,7 +22,7 @@ import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.ActionResponse;
import org.elasticsearch.action.support.IndicesOptions;
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.util.ArrayUtils;
public abstract class ClusterInfoRequestBuilder<Request extends ClusterInfoRequest<Request>, Response extends ActionResponse,
@ -30,7 +30,7 @@ public abstract class ClusterInfoRequestBuilder<Request extends ClusterInfoReque
extends MasterNodeReadOperationRequestBuilder<Request, Response, Builder> {
protected ClusterInfoRequestBuilder(ElasticsearchClient client, ActionType<Response> action, Request request) {
protected ClusterInfoRequestBuilder(OpenSearchClient client, ActionType<Response> action, Request request) {
super(client, action, request);
}

View File

@ -21,14 +21,14 @@ package org.elasticsearch.action.support.nodes;
import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.unit.TimeValue;
public abstract class NodesOperationRequestBuilder<Request extends BaseNodesRequest<Request>, Response extends BaseNodesResponse,
RequestBuilder extends NodesOperationRequestBuilder<Request, Response, RequestBuilder>>
extends ActionRequestBuilder<Request, Response> {
protected NodesOperationRequestBuilder(ElasticsearchClient client, ActionType<Response> action, Request request) {
protected NodesOperationRequestBuilder(OpenSearchClient client, ActionType<Response> action, Request request) {
super(client, action, request);
}

View File

@ -23,14 +23,14 @@ import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.action.ActionResponse;
import org.elasticsearch.action.support.ActiveShardCount;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.unit.TimeValue;
public abstract class ReplicationRequestBuilder<Request extends ReplicationRequest<Request>, Response extends ActionResponse,
RequestBuilder extends ReplicationRequestBuilder<Request, Response, RequestBuilder>>
extends ActionRequestBuilder<Request, Response> {
protected ReplicationRequestBuilder(ElasticsearchClient client, ActionType<Response> action, Request request) {
protected ReplicationRequestBuilder(OpenSearchClient client, ActionType<Response> action, Request request) {
super(client, action, request);
}

View File

@ -22,14 +22,14 @@ package org.elasticsearch.action.support.single.instance;
import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.action.ActionResponse;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.unit.TimeValue;
public abstract class InstanceShardOperationRequestBuilder<Request extends InstanceShardOperationRequest<Request>,
Response extends ActionResponse, RequestBuilder extends InstanceShardOperationRequestBuilder<Request, Response, RequestBuilder>>
extends ActionRequestBuilder<Request, Response> {
protected InstanceShardOperationRequestBuilder(ElasticsearchClient client, ActionType<Response> action, Request request) {
protected InstanceShardOperationRequestBuilder(OpenSearchClient client, ActionType<Response> action, Request request) {
super(client, action, request);
}

View File

@ -22,13 +22,13 @@ package org.elasticsearch.action.support.single.shard;
import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.action.ActionResponse;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
public abstract class SingleShardOperationRequestBuilder<Request extends SingleShardRequest<Request>, Response extends ActionResponse,
RequestBuilder extends SingleShardOperationRequestBuilder<Request, Response, RequestBuilder>>
extends ActionRequestBuilder<Request, Response> {
protected SingleShardOperationRequestBuilder(ElasticsearchClient client, ActionType<Response> action, Request request) {
protected SingleShardOperationRequestBuilder(OpenSearchClient client, ActionType<Response> action, Request request) {
super(client, action, request);
}

View File

@ -20,7 +20,7 @@ package org.elasticsearch.action.support.tasks;
import org.elasticsearch.action.ActionType;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.tasks.TaskId;
@ -33,7 +33,7 @@ public class TasksRequestBuilder<
RequestBuilder extends TasksRequestBuilder<Request, Response, RequestBuilder>
> extends ActionRequestBuilder<Request, Response> {
protected TasksRequestBuilder(ElasticsearchClient client, ActionType<Response> action, Request request) {
protected TasksRequestBuilder(OpenSearchClient client, ActionType<Response> action, Request request) {
super(client, action, request);
}
@ -65,7 +65,7 @@ public class TasksRequestBuilder<
}
/**
* Match all children of the provided task.
* Match all children of the provided task.
*/
@SuppressWarnings("unchecked")
public final RequestBuilder setParentTaskId(TaskId taskId) {

View File

@ -20,12 +20,12 @@
package org.elasticsearch.action.termvectors;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.Nullable;
public class MultiTermVectorsRequestBuilder extends ActionRequestBuilder<MultiTermVectorsRequest, MultiTermVectorsResponse> {
public MultiTermVectorsRequestBuilder(ElasticsearchClient client, MultiTermVectorsAction action) {
public MultiTermVectorsRequestBuilder(OpenSearchClient client, MultiTermVectorsAction action) {
super(client, action, new MultiTermVectorsRequest());
}

View File

@ -20,7 +20,7 @@
package org.elasticsearch.action.termvectors;
import org.elasticsearch.action.ActionRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.index.VersionType;
@ -35,7 +35,7 @@ import java.util.Map;
*/
public class TermVectorsRequestBuilder extends ActionRequestBuilder<TermVectorsRequest, TermVectorsResponse> {
public TermVectorsRequestBuilder(ElasticsearchClient client, TermVectorsAction action) {
public TermVectorsRequestBuilder(OpenSearchClient client, TermVectorsAction action) {
super(client, action, new TermVectorsRequest());
}
@ -44,7 +44,7 @@ public class TermVectorsRequestBuilder extends ActionRequestBuilder<TermVectorsR
* from the provided index. Use {@code index}, {@code type} and
* {@code id} to specify the document to load.
*/
public TermVectorsRequestBuilder(ElasticsearchClient client, TermVectorsAction action, String index, String type, String id) {
public TermVectorsRequestBuilder(OpenSearchClient client, TermVectorsAction action, String index, String type, String id) {
super(client, action, new TermVectorsRequest(index, type, id));
}

View File

@ -24,7 +24,7 @@ import org.elasticsearch.action.support.ActiveShardCount;
import org.elasticsearch.action.support.WriteRequestBuilder;
import org.elasticsearch.action.support.replication.ReplicationRequest;
import org.elasticsearch.action.support.single.instance.InstanceShardOperationRequestBuilder;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.OpenSearchClient;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentType;
@ -36,11 +36,11 @@ import java.util.Map;
public class UpdateRequestBuilder extends InstanceShardOperationRequestBuilder<UpdateRequest, UpdateResponse, UpdateRequestBuilder>
implements WriteRequestBuilder<UpdateRequestBuilder> {
public UpdateRequestBuilder(ElasticsearchClient client, UpdateAction action) {
public UpdateRequestBuilder(OpenSearchClient client, UpdateAction action) {
super(client, action, new UpdateRequest());
}
public UpdateRequestBuilder(ElasticsearchClient client, UpdateAction action, String index, String type, String id) {
public UpdateRequestBuilder(OpenSearchClient client, UpdateAction action, String index, String type, String id) {
super(client, action, new UpdateRequest(index, type, id));
}

Some files were not shown because too many files have changed in this diff Show More