Package org.elasticsearch.client

Class Requests

java.lang.Object

org.elasticsearch.client.Requests

public class Requests
extends Object

A handy one stop shop for creating requests (make sure to import static this class).

Field Summary

Fields

Modifier and Type	Field	Description
static XContentType	CONTENT_TYPE	The content type used to generate request builders (query / search).
static XContentType	INDEX_CONTENT_TYPE	The default content type to use to generate source documents when indexing.

Constructor Summary

Constructors

Constructor	Description
Requests()

Method Summary

Modifier and Type	Method	Description
static BulkRequest	bulkRequest()	Creates a new bulk request.
static CancelTasksRequest	cancelTasksRequest()	Creates a nodes tasks request against one or more nodes.
static CleanupRepositoryRequest	cleanupRepositoryRequest(String name)	Cleanup repository
static ClearIndicesCacheRequest	clearIndicesCacheRequest(String... indices)	Creates a clean indices cache request.
static CloseIndexRequest	closeIndexRequest(String index)	Creates a close index request.
static ClusterHealthRequest	clusterHealthRequest(String... indices)	Creates a cluster health request.
static ClusterRerouteRequest	clusterRerouteRequest()
static ClusterSearchShardsRequest	clusterSearchShardsRequest()	List all shards for the give search
static ClusterSearchShardsRequest	clusterSearchShardsRequest(String... indices)	List all shards for the give search
static ClusterStateRequest	clusterStateRequest()	Creates a cluster state request.
static ClusterStatsRequest	clusterStatsRequest()	Creates a cluster stats request.
static ClusterUpdateSettingsRequest	clusterUpdateSettingsRequest()
static CreateIndexRequest	createIndexRequest(String index)	Creates a create index request.
static CreateSnapshotRequest	createSnapshotRequest(String repository, String snapshot)	Creates new snapshot
static DeleteIndexRequest	deleteIndexRequest(String index)	Creates a delete index request.
static DeleteRepositoryRequest	deleteRepositoryRequest(String name)	Deletes registration for snapshot repository
static DeleteRequest	deleteRequest(String index)	Creates a delete request against a specific index.
static DeleteSnapshotRequest	deleteSnapshotRequest(String repository, String... snapshots)	Deletes snapshots
static FlushRequest	flushRequest(String... indices)	Creates a flush indices request.
static ForceMergeRequest	forceMergeRequest(String... indices)	Creates a force merge request.
static GetRepositoriesRequest	getRepositoryRequest(String... repositories)	Gets snapshot repository
static GetRequest	getRequest(String index)	Creates a get request to get the JSON source from an index based on a type and id.
static GetSnapshotsRequest	getSnapshotsRequest(String... repositories)	Gets snapshots from repositories
static GetTaskRequest	getTaskRequest()	Creates a get task request.
static IndicesAliasesRequest	indexAliasesRequest()	Creates an index aliases request allowing to add and remove aliases.
static IndexRequest	indexRequest()
static IndexRequest	indexRequest(String index)	Create an index request against a specific index.
static IndicesExistsRequest	indicesExistsRequest(String... indices)	Creates an indices exists request.
static IndicesSegmentsRequest	indicesSegmentsRequest(String... indices)
static IndicesShardStoresRequest	indicesShardStoresRequest(String... indices)	Creates an indices shard stores info request.
static ListTasksRequest	listTasksRequest()	Creates a nodes tasks request against all the nodes.
static NodesInfoRequest	nodesInfoRequest()	Creates a nodes info request against all the nodes.
static NodesInfoRequest	nodesInfoRequest(String... nodesIds)	Creates a nodes info request against one or more nodes.
static NodesStatsRequest	nodesStatsRequest(String... nodesIds)	Creates a nodes stats request against one or more nodes.
static NodesUsageRequest	nodesUsageRequest(String... nodesIds)	Creates a nodes usage request against one or more nodes.
static OpenIndexRequest	openIndexRequest(String index)	Creates an open index request.
static PutMappingRequest	putMappingRequest(String... indices)	Create a create mapping request against one or more indices.
static PutRepositoryRequest	putRepositoryRequest(String name)	Registers snapshot repository
static RefreshRequest	refreshRequest(String... indices)	Creates a refresh indices request.
static RestoreSnapshotRequest	restoreSnapshotRequest(String repository, String snapshot)	Restores new snapshot
static SearchRequest	searchRequest(String... indices)	Creates a search request against one or more indices.
static SearchScrollRequest	searchScrollRequest(String scrollId)	Creates a search scroll request allowing to continue searching a previous search request.
static SnapshotsStatusRequest	snapshotsStatusRequest(String repository)	Get status of snapshots
static SyncedFlushRequest	syncedFlushRequest(String... indices)	Creates a synced flush indices request.
static UpdateSettingsRequest	updateSettingsRequest(String... indices)	A request to update indices settings.
static UpgradeRequest	upgradeRequest(String... indices)	Creates an upgrade request.
static VerifyRepositoryRequest	verifyRepositoryRequest(String name)	Verifies snapshot repository

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CONTENT_TYPE

public static XContentType CONTENT_TYPE

The content type used to generate request builders (query / search).

INDEX_CONTENT_TYPE

public static XContentType INDEX_CONTENT_TYPE

The default content type to use to generate source documents when indexing.

Constructor Details

Requests

public Requests()

Method Details

indexRequest

public static IndexRequest indexRequest()

indexRequest

public static IndexRequest indexRequest(String index)

Create an index request against a specific index. Note the IndexRequest.type(String) must be set as well and optionally the IndexRequest.id(String).

Parameters:

index - The index name to index the request against

Returns:

The index request

See Also:

• Client.index(org.elasticsearch.action.index.IndexRequest)

deleteRequest

public static DeleteRequest deleteRequest(String index)

Creates a delete request against a specific index. Note the DeleteRequest.type(String) and DeleteRequest.id(String) must be set.

Parameters:

index - The index name to delete from

Returns:

The delete request

See Also:

• Client.delete(org.elasticsearch.action.delete.DeleteRequest)

bulkRequest

public static BulkRequest bulkRequest()

Creates a new bulk request.

getRequest

public static GetRequest getRequest(String index)

Creates a get request to get the JSON source from an index based on a type and id. Note, the GetRequest.type(String) and GetRequest.id(String) must be set.

Parameters:

index - The index to get the JSON source from

Returns:

The get request

See Also:

• Client.get(org.elasticsearch.action.get.GetRequest)

searchRequest

public static SearchRequest searchRequest(String... indices)

Creates a search request against one or more indices. Note, the search source must be set either using the actual JSON search source, or the SearchSourceBuilder.

Parameters:

indices - The indices to search against. Use null or _all to execute against all indices

Returns:

The search request

See Also:

• Client.search(org.elasticsearch.action.search.SearchRequest)

searchScrollRequest

public static SearchScrollRequest searchScrollRequest(String scrollId)

Creates a search scroll request allowing to continue searching a previous search request.

Parameters:

scrollId - The scroll id representing the scrollable search

Returns:

The search scroll request

See Also:

• Client.searchScroll(org.elasticsearch.action.search.SearchScrollRequest)

indicesSegmentsRequest

public static IndicesSegmentsRequest indicesSegmentsRequest(String... indices)

indicesShardStoresRequest

public static IndicesShardStoresRequest indicesShardStoresRequest(String... indices)

Creates an indices shard stores info request.

Parameters:

indices - The indices to get shard store information on

Returns:

The indices shard stores request

See Also:

• IndicesAdminClient.shardStores(IndicesShardStoresRequest)

indicesExistsRequest

public static IndicesExistsRequest indicesExistsRequest(String... indices)

Creates an indices exists request.

Parameters:

indices - The indices to check if they exists or not.

Returns:

The indices exists request

See Also:

• IndicesAdminClient.exists(org.elasticsearch.action.admin.indices.exists.indices.IndicesExistsRequest)

createIndexRequest

public static CreateIndexRequest createIndexRequest(String index)

Creates a create index request.

Parameters:

index - The index to create

Returns:

The index create request

See Also:

• IndicesAdminClient.create(org.elasticsearch.action.admin.indices.create.CreateIndexRequest)

deleteIndexRequest

public static DeleteIndexRequest deleteIndexRequest(String index)

Creates a delete index request.

Parameters:

index - The index to delete

Returns:

The delete index request

See Also:

• IndicesAdminClient.delete(org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest)

closeIndexRequest

public static CloseIndexRequest closeIndexRequest(String index)

Creates a close index request.

Parameters:

index - The index to close

Returns:

The delete index request

See Also:

• IndicesAdminClient.close(org.elasticsearch.action.admin.indices.close.CloseIndexRequest)

openIndexRequest

public static OpenIndexRequest openIndexRequest(String index)

Creates an open index request.

Parameters:

index - The index to open

Returns:

The delete index request

See Also:

• IndicesAdminClient.open(org.elasticsearch.action.admin.indices.open.OpenIndexRequest)

putMappingRequest

public static PutMappingRequest putMappingRequest(String... indices)

Create a create mapping request against one or more indices.

Parameters:

indices - The indices to create mapping. Use null or _all to execute against all indices

Returns:

The create mapping request

See Also:

• IndicesAdminClient.putMapping(org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest)

indexAliasesRequest

public static IndicesAliasesRequest indexAliasesRequest()

Creates an index aliases request allowing to add and remove aliases.

Returns:

The index aliases request

refreshRequest

public static RefreshRequest refreshRequest(String... indices)

Creates a refresh indices request.

Parameters:

indices - The indices to refresh. Use null or _all to execute against all indices

Returns:

The refresh request

See Also:

• IndicesAdminClient.refresh(org.elasticsearch.action.admin.indices.refresh.RefreshRequest)

flushRequest

public static FlushRequest flushRequest(String... indices)

Creates a flush indices request.

Parameters:

indices - The indices to flush. Use null or _all to execute against all indices

Returns:

The flush request

See Also:

• IndicesAdminClient.flush(org.elasticsearch.action.admin.indices.flush.FlushRequest)

syncedFlushRequest

public static SyncedFlushRequest syncedFlushRequest(String... indices)

Creates a synced flush indices request.

Parameters:

indices - The indices to sync flush. Use null or _all to execute against all indices

Returns:

The synced flush request

See Also:

• IndicesAdminClient.syncedFlush(SyncedFlushRequest)

forceMergeRequest

public static ForceMergeRequest forceMergeRequest(String... indices)

Creates a force merge request.

Parameters:

indices - The indices to force merge. Use null or _all to execute against all indices

Returns:

The force merge request

See Also:

• IndicesAdminClient.forceMerge(org.elasticsearch.action.admin.indices.forcemerge.ForceMergeRequest)

upgradeRequest

public static UpgradeRequest upgradeRequest(String... indices)

Creates an upgrade request.

Parameters:

indices - The indices to upgrade. Use null or _all to execute against all indices

Returns:

The upgrade request

See Also:

• IndicesAdminClient.upgrade(UpgradeRequest)

clearIndicesCacheRequest

public static ClearIndicesCacheRequest clearIndicesCacheRequest(String... indices)

Creates a clean indices cache request.

Parameters:

indices - The indices to clean their caches. Use null or _all to execute against all indices

Returns:

The request

updateSettingsRequest

public static UpdateSettingsRequest updateSettingsRequest(String... indices)

A request to update indices settings.

Parameters:

indices - The indices to update the settings for. Use null or _all to executed against all indices.

Returns:

The request

clusterStateRequest

public static ClusterStateRequest clusterStateRequest()

Creates a cluster state request.

Returns:

The cluster state request.

See Also:

• ClusterAdminClient.state(org.elasticsearch.action.admin.cluster.state.ClusterStateRequest)

clusterRerouteRequest

public static ClusterRerouteRequest clusterRerouteRequest()

clusterUpdateSettingsRequest

public static ClusterUpdateSettingsRequest clusterUpdateSettingsRequest()

clusterHealthRequest

public static ClusterHealthRequest clusterHealthRequest(String... indices)

Creates a cluster health request.

Parameters:

indices - The indices to provide additional cluster health information for. Use null or _all to execute against all indices

Returns:

The cluster health request

See Also:

• ClusterAdminClient.health(org.elasticsearch.action.admin.cluster.health.ClusterHealthRequest)

clusterSearchShardsRequest

public static ClusterSearchShardsRequest clusterSearchShardsRequest()

List all shards for the give search

clusterSearchShardsRequest

public static ClusterSearchShardsRequest clusterSearchShardsRequest(String... indices)

List all shards for the give search

nodesInfoRequest

public static NodesInfoRequest nodesInfoRequest()

Creates a nodes info request against all the nodes.

Returns:

The nodes info request

See Also:

• ClusterAdminClient.nodesInfo(org.elasticsearch.action.admin.cluster.node.info.NodesInfoRequest)

nodesInfoRequest

public static NodesInfoRequest nodesInfoRequest(String... nodesIds)

Creates a nodes info request against one or more nodes. Pass null or an empty array for all nodes.

Parameters:

nodesIds - The nodes ids to get the status for

Returns:

The nodes info request

See Also:

• ClusterAdminClient.nodesStats(org.elasticsearch.action.admin.cluster.node.stats.NodesStatsRequest)

nodesStatsRequest

public static NodesStatsRequest nodesStatsRequest(String... nodesIds)

Creates a nodes stats request against one or more nodes. Pass null or an empty array for all nodes.

Parameters:

nodesIds - The nodes ids to get the stats for

Returns:

The nodes info request

See Also:

• ClusterAdminClient.nodesStats(org.elasticsearch.action.admin.cluster.node.stats.NodesStatsRequest)

nodesUsageRequest

public static NodesUsageRequest nodesUsageRequest(String... nodesIds)

Creates a nodes usage request against one or more nodes. Pass null or an empty array for all nodes.

Parameters:

nodesIds - The nodes ids to get the usage for

Returns:

The nodes usage request

See Also:

• ClusterAdminClient.nodesUsage(org.elasticsearch.action.admin.cluster.node.usage.NodesUsageRequest)

clusterStatsRequest

public static ClusterStatsRequest clusterStatsRequest()

Creates a cluster stats request.

Returns:

The cluster stats request

See Also:

• ClusterAdminClient.clusterStats(org.elasticsearch.action.admin.cluster.stats.ClusterStatsRequest)

listTasksRequest

public static ListTasksRequest listTasksRequest()

Creates a nodes tasks request against all the nodes.

Returns:

The nodes tasks request

See Also:

• ClusterAdminClient.listTasks(ListTasksRequest)

getTaskRequest

public static GetTaskRequest getTaskRequest()

Creates a get task request.

Returns:

The nodes tasks request

See Also:

• ClusterAdminClient.getTask(GetTaskRequest)

cancelTasksRequest

public static CancelTasksRequest cancelTasksRequest()

Creates a nodes tasks request against one or more nodes. Pass null or an empty array for all nodes.

Returns:

The nodes tasks request

See Also:

• ClusterAdminClient.cancelTasks(CancelTasksRequest)

putRepositoryRequest

public static PutRepositoryRequest putRepositoryRequest(String name)

Registers snapshot repository

Parameters:

name - repository name

Returns:

repository registration request

getRepositoryRequest

public static GetRepositoriesRequest getRepositoryRequest(String... repositories)

Gets snapshot repository

Parameters:

repositories - names of repositories

Returns:

get repository request

deleteRepositoryRequest

public static DeleteRepositoryRequest deleteRepositoryRequest(String name)

Deletes registration for snapshot repository

Parameters:

name - repository name

Returns:

delete repository request

cleanupRepositoryRequest

public static CleanupRepositoryRequest cleanupRepositoryRequest(String name)

Cleanup repository

Parameters:

name - repository name

Returns:

cleanup repository request

verifyRepositoryRequest

public static VerifyRepositoryRequest verifyRepositoryRequest(String name)

Verifies snapshot repository

Parameters:

name - repository name

Returns:

repository verification request

createSnapshotRequest

public static CreateSnapshotRequest createSnapshotRequest(String repository,
 String snapshot)

Creates new snapshot

Parameters:

repository - repository name

snapshot - snapshot name

Returns:

create snapshot request

getSnapshotsRequest

public static GetSnapshotsRequest getSnapshotsRequest(String... repositories)

Gets snapshots from repositories

Parameters:

repositories - repository names

Returns:

get snapshot request

restoreSnapshotRequest

public static RestoreSnapshotRequest restoreSnapshotRequest(String repository,
 String snapshot)

Restores new snapshot

Parameters:

repository - repository name

snapshot - snapshot name

Returns:

snapshot creation request

deleteSnapshotRequest

public static DeleteSnapshotRequest deleteSnapshotRequest(String repository,
 String... snapshots)

Deletes snapshots

Parameters:

snapshots - snapshot names

repository - repository name

Returns:

delete snapshot request

snapshotsStatusRequest

public static SnapshotsStatusRequest snapshotsStatusRequest(String repository)

Get status of snapshots

Parameters:

repository - repository name

Returns:

snapshot status request