org.elasticsearch.client

Interface ClusterAdminClient

All Superinterfaces:

ElasticsearchClient

public interface ClusterAdminClient
extends ElasticsearchClient

Administrative actions/operations against indices.

See Also:

AdminClient.cluster()

Method Summary

Modifier and Type	Method and Description
ActionFuture<ClusterAllocationExplainResponse>	allocationExplain(ClusterAllocationExplainRequest request) Explain the allocation of a shard
void	allocationExplain(ClusterAllocationExplainRequest request, ActionListener<ClusterAllocationExplainResponse> listener) Explain the allocation of a shard
ActionFuture<CancelTasksResponse>	cancelTasks(CancelTasksRequest request) Cancel tasks
void	cancelTasks(CancelTasksRequest request, ActionListener<CancelTasksResponse> listener) Cancel active tasks
ActionFuture<ClusterStatsResponse>	clusterStats(ClusterStatsRequest request) Cluster wide aggregated stats.
void	clusterStats(ClusterStatsRequest request, ActionListener<ClusterStatsResponse> listener) Cluster wide aggregated stats
ActionFuture<CreateSnapshotResponse>	createSnapshot(CreateSnapshotRequest request) Creates a new snapshot.
void	createSnapshot(CreateSnapshotRequest request, ActionListener<CreateSnapshotResponse> listener) Creates a new snapshot.
ActionFuture<WritePipelineResponse>	deletePipeline(DeletePipelineRequest request) Deletes a stored ingest pipeline
void	deletePipeline(DeletePipelineRequest request, ActionListener<WritePipelineResponse> listener) Deletes a stored ingest pipeline
ActionFuture<DeleteRepositoryResponse>	deleteRepository(DeleteRepositoryRequest request) Unregisters a repository.
void	deleteRepository(DeleteRepositoryRequest request, ActionListener<DeleteRepositoryResponse> listener) Unregisters a repository.
ActionFuture<DeleteSnapshotResponse>	deleteSnapshot(DeleteSnapshotRequest request) Delete snapshot.
void	deleteSnapshot(DeleteSnapshotRequest request, ActionListener<DeleteSnapshotResponse> listener) Delete snapshot.
ActionFuture<DeleteStoredScriptResponse>	deleteStoredScript(DeleteStoredScriptRequest request) Delete a script from the cluster state
void	deleteStoredScript(DeleteStoredScriptRequest request, ActionListener<DeleteStoredScriptResponse> listener) Delete a script from the cluster state
ActionFuture<GetPipelineResponse>	getPipeline(GetPipelineRequest request) Returns a stored ingest pipeline
void	getPipeline(GetPipelineRequest request, ActionListener<GetPipelineResponse> listener) Returns a stored ingest pipeline
ActionFuture<GetRepositoriesResponse>	getRepositories(GetRepositoriesRequest request) Gets repositories.
void	getRepositories(GetRepositoriesRequest request, ActionListener<GetRepositoriesResponse> listener) Gets repositories.
ActionFuture<GetSnapshotsResponse>	getSnapshots(GetSnapshotsRequest request) Get snapshot.
void	getSnapshots(GetSnapshotsRequest request, ActionListener<GetSnapshotsResponse> listener) Get snapshot.
ActionFuture<GetStoredScriptResponse>	getStoredScript(GetStoredScriptRequest request) Get a script from the cluster state
void	getStoredScript(GetStoredScriptRequest request, ActionListener<GetStoredScriptResponse> listener) Get a script from the cluster state
ActionFuture<GetTaskResponse>	getTask(GetTaskRequest request) Get a task.
void	getTask(GetTaskRequest request, ActionListener<GetTaskResponse> listener) Get a task.
ActionFuture<ClusterHealthResponse>	health(ClusterHealthRequest request) The health of the cluster.
void	health(ClusterHealthRequest request, ActionListener<ClusterHealthResponse> listener) The health of the cluster.
ActionFuture<ListTasksResponse>	listTasks(ListTasksRequest request) List tasks
void	listTasks(ListTasksRequest request, ActionListener<ListTasksResponse> listener) List active tasks
ActionFuture<NodesHotThreadsResponse>	nodesHotThreads(NodesHotThreadsRequest request) Returns top N hot-threads samples per node.
void	nodesHotThreads(NodesHotThreadsRequest request, ActionListener<NodesHotThreadsResponse> listener) Returns top N hot-threads samples per node.
ActionFuture<NodesInfoResponse>	nodesInfo(NodesInfoRequest request) Nodes info of the cluster.
void	nodesInfo(NodesInfoRequest request, ActionListener<NodesInfoResponse> listener) Nodes info of the cluster.
ActionFuture<NodesStatsResponse>	nodesStats(NodesStatsRequest request) Nodes stats of the cluster.
void	nodesStats(NodesStatsRequest request, ActionListener<NodesStatsResponse> listener) Nodes stats of the cluster.
ActionFuture<PendingClusterTasksResponse>	pendingClusterTasks(PendingClusterTasksRequest request) Returns a list of the pending cluster tasks, that are scheduled to be executed.
void	pendingClusterTasks(PendingClusterTasksRequest request, ActionListener<PendingClusterTasksResponse> listener) Returns a list of the pending cluster tasks, that are scheduled to be executed.
ClusterAllocationExplainRequestBuilder	prepareAllocationExplain() Explain the allocation of a shard
CancelTasksRequestBuilder	prepareCancelTasks(java.lang.String... nodesIds) Cancel active tasks
ClusterStatsRequestBuilder	prepareClusterStats()
CreateSnapshotRequestBuilder	prepareCreateSnapshot(java.lang.String repository, java.lang.String name) Creates a new snapshot.
DeletePipelineRequestBuilder	prepareDeletePipeline() Deletes a stored ingest pipeline
DeletePipelineRequestBuilder	prepareDeletePipeline(java.lang.String id) Deletes a stored ingest pipeline
DeleteRepositoryRequestBuilder	prepareDeleteRepository(java.lang.String name) Unregisters a repository.
DeleteSnapshotRequestBuilder	prepareDeleteSnapshot(java.lang.String repository, java.lang.String snapshot) Delete snapshot.
DeleteStoredScriptRequestBuilder	prepareDeleteStoredScript() Delete a script from the cluster state
DeleteStoredScriptRequestBuilder	prepareDeleteStoredScript(java.lang.String scriptLang, java.lang.String id) Delete a script from the cluster state
GetPipelineRequestBuilder	prepareGetPipeline(java.lang.String... ids) Returns a stored ingest pipeline
GetRepositoriesRequestBuilder	prepareGetRepositories(java.lang.String... name) Gets repositories.
GetSnapshotsRequestBuilder	prepareGetSnapshots(java.lang.String repository) Get snapshot.
GetStoredScriptRequestBuilder	prepareGetStoredScript() Get a script from the cluster state
GetStoredScriptRequestBuilder	prepareGetStoredScript(java.lang.String scriptLang, java.lang.String id) Get a script from the cluster state
GetTaskRequestBuilder	prepareGetTask(java.lang.String taskId) Fetch a task by id.
GetTaskRequestBuilder	prepareGetTask(TaskId taskId) Fetch a task by id.
ClusterHealthRequestBuilder	prepareHealth(java.lang.String... indices) The health of the cluster.
ListTasksRequestBuilder	prepareListTasks(java.lang.String... nodesIds) List active tasks
NodesHotThreadsRequestBuilder	prepareNodesHotThreads(java.lang.String... nodesIds) Returns a request builder to fetch top N hot-threads samples per node.
NodesInfoRequestBuilder	prepareNodesInfo(java.lang.String... nodesIds) Nodes info of the cluster.
NodesStatsRequestBuilder	prepareNodesStats(java.lang.String... nodesIds) Nodes stats of the cluster.
PendingClusterTasksRequestBuilder	preparePendingClusterTasks() Returns a list of the pending cluster tasks, that are scheduled to be executed.
PutPipelineRequestBuilder	preparePutPipeline(java.lang.String id, BytesReference source) Deprecated. use preparePutPipeline(String, BytesReference, XContentType)
PutPipelineRequestBuilder	preparePutPipeline(java.lang.String id, BytesReference source, XContentType xContentType) Stores an ingest pipeline
PutRepositoryRequestBuilder	preparePutRepository(java.lang.String name) Registers a snapshot repository.
PutStoredScriptRequestBuilder	preparePutStoredScript() Store a script in the cluster state
ClusterRerouteRequestBuilder	prepareReroute() Update settings in the cluster.
RestoreSnapshotRequestBuilder	prepareRestoreSnapshot(java.lang.String repository, java.lang.String snapshot) Restores a snapshot.
ClusterSearchShardsRequestBuilder	prepareSearchShards() Returns list of shards the given search would be executed on.
ClusterSearchShardsRequestBuilder	prepareSearchShards(java.lang.String... indices) Returns list of shards the given search would be executed on.
SimulatePipelineRequestBuilder	prepareSimulatePipeline(BytesReference source) Deprecated.
SimulatePipelineRequestBuilder	prepareSimulatePipeline(BytesReference source, XContentType xContentType) Simulates an ingest pipeline
SnapshotsStatusRequestBuilder	prepareSnapshotStatus() Get snapshot status.
SnapshotsStatusRequestBuilder	prepareSnapshotStatus(java.lang.String repository) Get snapshot status.
ClusterStateRequestBuilder	prepareState() The state of the cluster.
ClusterUpdateSettingsRequestBuilder	prepareUpdateSettings() Update settings in the cluster.
VerifyRepositoryRequestBuilder	prepareVerifyRepository(java.lang.String name) Verifies a repository.
ActionFuture<WritePipelineResponse>	putPipeline(PutPipelineRequest request) Stores an ingest pipeline
void	putPipeline(PutPipelineRequest request, ActionListener<WritePipelineResponse> listener) Stores an ingest pipeline
ActionFuture<PutRepositoryResponse>	putRepository(PutRepositoryRequest request) Registers a snapshot repository.
void	putRepository(PutRepositoryRequest request, ActionListener<PutRepositoryResponse> listener) Registers a snapshot repository.
ActionFuture<PutStoredScriptResponse>	putStoredScript(PutStoredScriptRequest request) Store a script in the cluster state
void	putStoredScript(PutStoredScriptRequest request, ActionListener<PutStoredScriptResponse> listener) Store a script in the cluster state
ActionFuture<ClusterRerouteResponse>	reroute(ClusterRerouteRequest request) Reroutes allocation of shards.
void	reroute(ClusterRerouteRequest request, ActionListener<ClusterRerouteResponse> listener) Reroutes allocation of shards.
ActionFuture<RestoreSnapshotResponse>	restoreSnapshot(RestoreSnapshotRequest request) Restores a snapshot.
void	restoreSnapshot(RestoreSnapshotRequest request, ActionListener<RestoreSnapshotResponse> listener) Restores a snapshot.
ActionFuture<ClusterSearchShardsResponse>	searchShards(ClusterSearchShardsRequest request) Returns list of shards the given search would be executed on.
void	searchShards(ClusterSearchShardsRequest request, ActionListener<ClusterSearchShardsResponse> listener) Returns list of shards the given search would be executed on.
ActionFuture<SimulatePipelineResponse>	simulatePipeline(SimulatePipelineRequest request) Simulates an ingest pipeline
void	simulatePipeline(SimulatePipelineRequest request, ActionListener<SimulatePipelineResponse> listener) Simulates an ingest pipeline
ActionFuture<SnapshotsStatusResponse>	snapshotsStatus(SnapshotsStatusRequest request) Get snapshot status.
void	snapshotsStatus(SnapshotsStatusRequest request, ActionListener<SnapshotsStatusResponse> listener) Get snapshot status.
ActionFuture<ClusterStateResponse>	state(ClusterStateRequest request) The state of the cluster.
void	state(ClusterStateRequest request, ActionListener<ClusterStateResponse> listener) The state of the cluster.
ActionFuture<ClusterUpdateSettingsResponse>	updateSettings(ClusterUpdateSettingsRequest request) Updates settings in the cluster.
void	updateSettings(ClusterUpdateSettingsRequest request, ActionListener<ClusterUpdateSettingsResponse> listener) Update settings in the cluster.
ActionFuture<VerifyRepositoryResponse>	verifyRepository(VerifyRepositoryRequest request) Verifies a repository.
void	verifyRepository(VerifyRepositoryRequest request, ActionListener<VerifyRepositoryResponse> listener) Verifies a repository.

Methods inherited from interface org.elasticsearch.client.ElasticsearchClient

execute, execute, prepareExecute, threadPool

Method Detail

health

ActionFuture<ClusterHealthResponse> health(ClusterHealthRequest request)

The health of the cluster.

Parameters:

request - The cluster state request

Returns:

The result future

See Also:

Requests.clusterHealthRequest(String...)

health

void health(ClusterHealthRequest request,
            ActionListener<ClusterHealthResponse> listener)

The health of the cluster.

Parameters:

request - The cluster state request

listener - A listener to be notified with a result

See Also:

Requests.clusterHealthRequest(String...)

prepareHealth

ClusterHealthRequestBuilder prepareHealth(java.lang.String... indices)

The health of the cluster.

state

ActionFuture<ClusterStateResponse> state(ClusterStateRequest request)

The state of the cluster.

Parameters:

request - The cluster state request.

Returns:

The result future

See Also:

Requests.clusterStateRequest()

state

void state(ClusterStateRequest request,
           ActionListener<ClusterStateResponse> listener)

The state of the cluster.

Parameters:

request - The cluster state request.

listener - A listener to be notified with a result

See Also:

Requests.clusterStateRequest()

prepareState

ClusterStateRequestBuilder prepareState()

The state of the cluster.

updateSettings

ActionFuture<ClusterUpdateSettingsResponse> updateSettings(ClusterUpdateSettingsRequest request)

Updates settings in the cluster.

updateSettings

void updateSettings(ClusterUpdateSettingsRequest request,
                    ActionListener<ClusterUpdateSettingsResponse> listener)

Update settings in the cluster.

prepareUpdateSettings

ClusterUpdateSettingsRequestBuilder prepareUpdateSettings()

Update settings in the cluster.

reroute

ActionFuture<ClusterRerouteResponse> reroute(ClusterRerouteRequest request)

Reroutes allocation of shards. Advance API.

reroute

void reroute(ClusterRerouteRequest request,
             ActionListener<ClusterRerouteResponse> listener)

Reroutes allocation of shards. Advance API.

prepareReroute

ClusterRerouteRequestBuilder prepareReroute()

Update settings in the cluster.

nodesInfo

ActionFuture<NodesInfoResponse> nodesInfo(NodesInfoRequest request)

Nodes info of the cluster.

Parameters:

request - The nodes info request

Returns:

The result future

See Also:

Requests.nodesInfoRequest(String...)

nodesInfo

void nodesInfo(NodesInfoRequest request,
               ActionListener<NodesInfoResponse> listener)

Nodes info of the cluster.

Parameters:

request - The nodes info request

listener - A listener to be notified with a result

See Also:

Requests.nodesInfoRequest(String...)

prepareNodesInfo

NodesInfoRequestBuilder prepareNodesInfo(java.lang.String... nodesIds)

Nodes info of the cluster.

clusterStats

ActionFuture<ClusterStatsResponse> clusterStats(ClusterStatsRequest request)

Cluster wide aggregated stats.

Parameters:

request - The cluster stats request

Returns:

The result future

See Also:

Requests.clusterStatsRequest()

clusterStats

void clusterStats(ClusterStatsRequest request,
                  ActionListener<ClusterStatsResponse> listener)

Cluster wide aggregated stats

Parameters:

request - The cluster stats request

listener - A listener to be notified with a result

See Also:

Requests.clusterStatsRequest()

prepareClusterStats

ClusterStatsRequestBuilder prepareClusterStats()

nodesStats

ActionFuture<NodesStatsResponse> nodesStats(NodesStatsRequest request)

Nodes stats of the cluster.

Parameters:

request - The nodes stats request

Returns:

The result future

See Also:

Requests.nodesStatsRequest(String...)

nodesStats

void nodesStats(NodesStatsRequest request,
                ActionListener<NodesStatsResponse> listener)

Nodes stats of the cluster.

Parameters:

request - The nodes info request

listener - A listener to be notified with a result

See Also:

Requests.nodesStatsRequest(String...)

prepareNodesStats

NodesStatsRequestBuilder prepareNodesStats(java.lang.String... nodesIds)

Nodes stats of the cluster.

nodesHotThreads

ActionFuture<NodesHotThreadsResponse> nodesHotThreads(NodesHotThreadsRequest request)

Returns top N hot-threads samples per node. The hot-threads are only sampled for the node ids specified in the request.

nodesHotThreads

void nodesHotThreads(NodesHotThreadsRequest request,
                     ActionListener<NodesHotThreadsResponse> listener)

Returns top N hot-threads samples per node. The hot-threads are only sampled for the node ids specified in the request.

prepareNodesHotThreads

NodesHotThreadsRequestBuilder prepareNodesHotThreads(java.lang.String... nodesIds)

Returns a request builder to fetch top N hot-threads samples per node. The hot-threads are only sampled for the node ids provided. Note: Use * to fetch samples for all nodes

listTasks

ActionFuture<ListTasksResponse> listTasks(ListTasksRequest request)

List tasks

Parameters:

request - The nodes tasks request

Returns:

The result future

See Also:

Requests.listTasksRequest()

listTasks

void listTasks(ListTasksRequest request,
               ActionListener<ListTasksResponse> listener)

List active tasks

Parameters:

request - The nodes tasks request

listener - A listener to be notified with a result

See Also:

Requests.listTasksRequest()

prepareListTasks

ListTasksRequestBuilder prepareListTasks(java.lang.String... nodesIds)

List active tasks

getTask

ActionFuture<GetTaskResponse> getTask(GetTaskRequest request)

Get a task.

Parameters:

request - the request

Returns:

the result future

See Also:

Requests.getTaskRequest()

getTask

void getTask(GetTaskRequest request,
             ActionListener<GetTaskResponse> listener)

Get a task.

Parameters:

request - the request

listener - A listener to be notified with the result

See Also:

Requests.getTaskRequest()

prepareGetTask

GetTaskRequestBuilder prepareGetTask(java.lang.String taskId)

Fetch a task by id.

prepareGetTask

GetTaskRequestBuilder prepareGetTask(TaskId taskId)

Fetch a task by id.

cancelTasks

ActionFuture<CancelTasksResponse> cancelTasks(CancelTasksRequest request)

Cancel tasks

Parameters:

request - The nodes tasks request

Returns:

The result future

See Also:

Requests.cancelTasksRequest()

cancelTasks

void cancelTasks(CancelTasksRequest request,
                 ActionListener<CancelTasksResponse> listener)

Cancel active tasks

Parameters:

request - The nodes tasks request

listener - A cancelener to be notified with a result

See Also:

Requests.cancelTasksRequest()

prepareCancelTasks

CancelTasksRequestBuilder prepareCancelTasks(java.lang.String... nodesIds)

Cancel active tasks

searchShards

ActionFuture<ClusterSearchShardsResponse> searchShards(ClusterSearchShardsRequest request)

Returns list of shards the given search would be executed on.

searchShards

void searchShards(ClusterSearchShardsRequest request,
                  ActionListener<ClusterSearchShardsResponse> listener)

Returns list of shards the given search would be executed on.

prepareSearchShards

ClusterSearchShardsRequestBuilder prepareSearchShards()

Returns list of shards the given search would be executed on.

prepareSearchShards

ClusterSearchShardsRequestBuilder prepareSearchShards(java.lang.String... indices)

Returns list of shards the given search would be executed on.

putRepository

ActionFuture<PutRepositoryResponse> putRepository(PutRepositoryRequest request)

Registers a snapshot repository.

putRepository

void putRepository(PutRepositoryRequest request,
                   ActionListener<PutRepositoryResponse> listener)

Registers a snapshot repository.

preparePutRepository

PutRepositoryRequestBuilder preparePutRepository(java.lang.String name)

Registers a snapshot repository.

deleteRepository

ActionFuture<DeleteRepositoryResponse> deleteRepository(DeleteRepositoryRequest request)

Unregisters a repository.

deleteRepository

void deleteRepository(DeleteRepositoryRequest request,
                      ActionListener<DeleteRepositoryResponse> listener)

Unregisters a repository.

prepareDeleteRepository

DeleteRepositoryRequestBuilder prepareDeleteRepository(java.lang.String name)

Unregisters a repository.

getRepositories

ActionFuture<GetRepositoriesResponse> getRepositories(GetRepositoriesRequest request)

Gets repositories.

getRepositories

void getRepositories(GetRepositoriesRequest request,
                     ActionListener<GetRepositoriesResponse> listener)

Gets repositories.

prepareGetRepositories

GetRepositoriesRequestBuilder prepareGetRepositories(java.lang.String... name)

Gets repositories.

verifyRepository

ActionFuture<VerifyRepositoryResponse> verifyRepository(VerifyRepositoryRequest request)

Verifies a repository.

verifyRepository

void verifyRepository(VerifyRepositoryRequest request,
                      ActionListener<VerifyRepositoryResponse> listener)

Verifies a repository.

prepareVerifyRepository

VerifyRepositoryRequestBuilder prepareVerifyRepository(java.lang.String name)

Verifies a repository.

createSnapshot

ActionFuture<CreateSnapshotResponse> createSnapshot(CreateSnapshotRequest request)

Creates a new snapshot.

createSnapshot

void createSnapshot(CreateSnapshotRequest request,
                    ActionListener<CreateSnapshotResponse> listener)

Creates a new snapshot.

prepareCreateSnapshot

CreateSnapshotRequestBuilder prepareCreateSnapshot(java.lang.String repository,
                                                   java.lang.String name)

Creates a new snapshot.

getSnapshots

ActionFuture<GetSnapshotsResponse> getSnapshots(GetSnapshotsRequest request)

Get snapshot.

getSnapshots

void getSnapshots(GetSnapshotsRequest request,
                  ActionListener<GetSnapshotsResponse> listener)

Get snapshot.

prepareGetSnapshots

GetSnapshotsRequestBuilder prepareGetSnapshots(java.lang.String repository)

Get snapshot.

deleteSnapshot

ActionFuture<DeleteSnapshotResponse> deleteSnapshot(DeleteSnapshotRequest request)

Delete snapshot.

deleteSnapshot

void deleteSnapshot(DeleteSnapshotRequest request,
                    ActionListener<DeleteSnapshotResponse> listener)

Delete snapshot.

prepareDeleteSnapshot

DeleteSnapshotRequestBuilder prepareDeleteSnapshot(java.lang.String repository,
                                                   java.lang.String snapshot)

Delete snapshot.

restoreSnapshot

ActionFuture<RestoreSnapshotResponse> restoreSnapshot(RestoreSnapshotRequest request)

Restores a snapshot.

restoreSnapshot

void restoreSnapshot(RestoreSnapshotRequest request,
                     ActionListener<RestoreSnapshotResponse> listener)

Restores a snapshot.

prepareRestoreSnapshot

RestoreSnapshotRequestBuilder prepareRestoreSnapshot(java.lang.String repository,
                                                     java.lang.String snapshot)

Restores a snapshot.

pendingClusterTasks

void pendingClusterTasks(PendingClusterTasksRequest request,
                         ActionListener<PendingClusterTasksResponse> listener)

Returns a list of the pending cluster tasks, that are scheduled to be executed. This includes operations that update the cluster state (for example, a create index operation)

pendingClusterTasks

ActionFuture<PendingClusterTasksResponse> pendingClusterTasks(PendingClusterTasksRequest request)

Returns a list of the pending cluster tasks, that are scheduled to be executed. This includes operations that update the cluster state (for example, a create index operation)

preparePendingClusterTasks

PendingClusterTasksRequestBuilder preparePendingClusterTasks()

Returns a list of the pending cluster tasks, that are scheduled to be executed. This includes operations that update the cluster state (for example, a create index operation)

snapshotsStatus

ActionFuture<SnapshotsStatusResponse> snapshotsStatus(SnapshotsStatusRequest request)

Get snapshot status.

snapshotsStatus

void snapshotsStatus(SnapshotsStatusRequest request,
                     ActionListener<SnapshotsStatusResponse> listener)

Get snapshot status.

prepareSnapshotStatus

SnapshotsStatusRequestBuilder prepareSnapshotStatus(java.lang.String repository)

Get snapshot status.

prepareSnapshotStatus

SnapshotsStatusRequestBuilder prepareSnapshotStatus()

Get snapshot status.

putPipeline

void putPipeline(PutPipelineRequest request,
                 ActionListener<WritePipelineResponse> listener)

Stores an ingest pipeline

putPipeline

ActionFuture<WritePipelineResponse> putPipeline(PutPipelineRequest request)

Stores an ingest pipeline

preparePutPipeline

@Deprecated
PutPipelineRequestBuilder preparePutPipeline(java.lang.String id,
                                                         BytesReference source)

Deprecated. use preparePutPipeline(String, BytesReference, XContentType)

Stores an ingest pipeline

preparePutPipeline

PutPipelineRequestBuilder preparePutPipeline(java.lang.String id,
                                             BytesReference source,
                                             XContentType xContentType)

Stores an ingest pipeline

deletePipeline

void deletePipeline(DeletePipelineRequest request,
                    ActionListener<WritePipelineResponse> listener)

Deletes a stored ingest pipeline

deletePipeline

ActionFuture<WritePipelineResponse> deletePipeline(DeletePipelineRequest request)

Deletes a stored ingest pipeline

prepareDeletePipeline

DeletePipelineRequestBuilder prepareDeletePipeline()

Deletes a stored ingest pipeline

prepareDeletePipeline

DeletePipelineRequestBuilder prepareDeletePipeline(java.lang.String id)

Deletes a stored ingest pipeline

getPipeline

void getPipeline(GetPipelineRequest request,
                 ActionListener<GetPipelineResponse> listener)

Returns a stored ingest pipeline

getPipeline

ActionFuture<GetPipelineResponse> getPipeline(GetPipelineRequest request)

Returns a stored ingest pipeline

prepareGetPipeline

GetPipelineRequestBuilder prepareGetPipeline(java.lang.String... ids)

Returns a stored ingest pipeline

simulatePipeline

void simulatePipeline(SimulatePipelineRequest request,
                      ActionListener<SimulatePipelineResponse> listener)

Simulates an ingest pipeline

simulatePipeline

ActionFuture<SimulatePipelineResponse> simulatePipeline(SimulatePipelineRequest request)

Simulates an ingest pipeline

prepareSimulatePipeline

@Deprecated
SimulatePipelineRequestBuilder prepareSimulatePipeline(BytesReference source)

Deprecated.

Simulates an ingest pipeline

prepareSimulatePipeline

SimulatePipelineRequestBuilder prepareSimulatePipeline(BytesReference source,
                                                       XContentType xContentType)

Simulates an ingest pipeline

allocationExplain

void allocationExplain(ClusterAllocationExplainRequest request,
                       ActionListener<ClusterAllocationExplainResponse> listener)

Explain the allocation of a shard

allocationExplain

ActionFuture<ClusterAllocationExplainResponse> allocationExplain(ClusterAllocationExplainRequest request)

Explain the allocation of a shard

prepareAllocationExplain

ClusterAllocationExplainRequestBuilder prepareAllocationExplain()

Explain the allocation of a shard

preparePutStoredScript

PutStoredScriptRequestBuilder preparePutStoredScript()

Store a script in the cluster state

deleteStoredScript

void deleteStoredScript(DeleteStoredScriptRequest request,
                        ActionListener<DeleteStoredScriptResponse> listener)

Delete a script from the cluster state

deleteStoredScript

ActionFuture<DeleteStoredScriptResponse> deleteStoredScript(DeleteStoredScriptRequest request)

Delete a script from the cluster state

prepareDeleteStoredScript

DeleteStoredScriptRequestBuilder prepareDeleteStoredScript()

Delete a script from the cluster state

prepareDeleteStoredScript

DeleteStoredScriptRequestBuilder prepareDeleteStoredScript(java.lang.String scriptLang,
                                                           java.lang.String id)

Delete a script from the cluster state

putStoredScript

void putStoredScript(PutStoredScriptRequest request,
                     ActionListener<PutStoredScriptResponse> listener)

Store a script in the cluster state

putStoredScript

ActionFuture<PutStoredScriptResponse> putStoredScript(PutStoredScriptRequest request)

Store a script in the cluster state

prepareGetStoredScript

GetStoredScriptRequestBuilder prepareGetStoredScript()

Get a script from the cluster state

prepareGetStoredScript

GetStoredScriptRequestBuilder prepareGetStoredScript(@Nullable
                                                     java.lang.String scriptLang,
                                                     java.lang.String id)

Get a script from the cluster state

getStoredScript

void getStoredScript(GetStoredScriptRequest request,
                     ActionListener<GetStoredScriptResponse> listener)

Get a script from the cluster state

getStoredScript

ActionFuture<GetStoredScriptResponse> getStoredScript(GetStoredScriptRequest request)

Get a script from the cluster state