Examples of ClusterStateRequest

Examples of org.elasticsearch.action.admin.cluster.state.ClusterStateRequest

53
54
55
56
57
58
59
60
61
62
63
    }

    @Override public void handleRequest(final RestRequest request, final RestChannel channel) {
        final String[] indices = splitIndices(request.param("index"));

        ClusterStateRequest clusterStateRequest = Requests.clusterStateRequest()
                .filterRoutingTable(true)
                .filterNodes(true)
                .filteredIndices(indices);

        client.admin().cluster().state(clusterStateRequest, new ActionListener<ClusterStateResponse>() {
View Full Code Here

Examples of org.elasticsearch.action.admin.cluster.state.ClusterStateRequest

52
53
54
55
56
57
58
59
60
61
62
    }

    @Override public void handleRequest(final RestRequest request, final RestChannel channel) {
        final String[] indices = splitIndices(request.param("index"));

        ClusterStateRequest clusterStateRequest = Requests.clusterStateRequest()
                .filterRoutingTable(true)
                .filterNodes(true)
                .filteredIndices(indices);

        client.admin().cluster().state(clusterStateRequest, new ActionListener<ClusterStateResponse>() {
View Full Code Here

Examples of org.elasticsearch.action.admin.cluster.state.ClusterStateRequest

30
31
32
33
34
35
36
* @author kimchy (shay.banon)
*/
public class ClusterStateRequestBuilder extends BaseClusterRequestBuilder<ClusterStateRequest, ClusterStateResponse> {

    public ClusterStateRequestBuilder(ClusterAdminClient clusterClient) {
        super(clusterClient, new ClusterStateRequest());
    }
View Full Code Here

Examples of org.elasticsearch.action.admin.cluster.state.ClusterStateRequest

70
71
72
73
74
75
76
77
78
79
80
        this.dumpRestorer = dumpRestorer;
    }

    //Just a shortcut to get all the available indexes with their types and aliases
    public JsonOutput availableIndices(String... indices) throws Exception {
        ClusterStateResponse response = this.client.admin().cluster().state(new ClusterStateRequest()
                .filterBlocks(true).filterNodes(true).filteredIndices(indices)
                .filterRoutingTable(true)).actionGet();

        XContentBuilder builder = JsonXContent.contentBuilder();
        builder.startObject();
View Full Code Here

Examples of org.elasticsearch.action.admin.cluster.state.ClusterStateRequest

101
102
103
104
105
106
107
108
109
110
111
        return stringToJson.stringToJson(builder.string());
    }

    //Just a shortcut to get all the available nodes within the cluster
    public JsonOutput availableNodes() throws Exception {
        ClusterStateResponse response = this.client.admin().cluster().state(new ClusterStateRequest()
                .filterBlocks(true).filterNodes(false).filterMetaData(true)
                .filterRoutingTable(true)).actionGet();

        XContentBuilder builder = JsonXContent.contentBuilder();
        builder.startObject();
View Full Code Here

Examples of org.elasticsearch.action.admin.cluster.state.ClusterStateRequest

42
43
44
45
46
47
48
49
50
*/
@SuppressWarnings("unused")
public class GetIndexTemplateRequestBuilder<JsonInput, JsonOutput> extends AbstractRequestBuilderJsonOutput<ClusterStateRequest, ClusterStateResponse, JsonInput, JsonOutput> {

    public GetIndexTemplateRequestBuilder(Client client, JsonToString<JsonInput> jsonToString, StringToJson<JsonOutput> stringToJson) {
        super(client, new ClusterStateRequest(), jsonToString, stringToJson);
        this.request.filterRoutingTable(true).filterNodes(true)
                .filteredIndices("_na").listenerThreaded(false);
    }
View Full Code Here

Examples of org.elasticsearch.action.admin.cluster.state.ClusterStateRequest

43
44
45
46
47
48
49
50
public class GetMappingRequestBuilder<JsonInput, JsonOutput> extends AbstractRequestBuilderJsonOutput<ClusterStateRequest, ClusterStateResponse, JsonInput, JsonOutput> {

    private String[] types;

    public GetMappingRequestBuilder(Client client, JsonToString<JsonInput> jsonToString, StringToJson<JsonOutput> stringToJson) {
        super(client, new ClusterStateRequest(), jsonToString, stringToJson);
        this.request.filterRoutingTable(true).filterNodes(true).listenerThreaded(false);
    }
View Full Code Here

Examples of org.elasticsearch.action.admin.cluster.state.ClusterStateRequest

37
38
39
40
41
42
43
44
*/
@SuppressWarnings("unused")
public class GetClusterSettingsRequestBuilder<JsonInput, JsonOutput> extends AbstractRequestBuilderJsonOutput<ClusterStateRequest, ClusterStateResponse, JsonInput, JsonOutput> {

    public GetClusterSettingsRequestBuilder(Client client, JsonToString<JsonInput> jsonToString, StringToJson<JsonOutput> stringToJson) {
        super(client, new ClusterStateRequest(), jsonToString, stringToJson);
        this.request.listenerThreaded(false).filterRoutingTable(true).filterNodes(true);
    }
View Full Code Here

Examples of org.elasticsearch.action.admin.cluster.state.ClusterStateRequest

39
40
41
42
43
44
45
46
*/
@SuppressWarnings("unused")
public class GetSettingsRequestBuilder<JsonInput, JsonOutput> extends AbstractRequestBuilderJsonOutput<ClusterStateRequest, ClusterStateResponse, JsonInput, JsonOutput> {

    public GetSettingsRequestBuilder(Client client, JsonToString<JsonInput> jsonToString, StringToJson<JsonOutput> stringToJson) {
        super(client, new ClusterStateRequest(), jsonToString, stringToJson);
        this.request.filterRoutingTable(true).filterNodes(true);
    }
View Full Code Here

Examples of org.elasticsearch.action.admin.cluster.state.ClusterStateRequest

40
41
42
43
44
45
46
47
*/
@SuppressWarnings("unused")
public class GetAliasesIndicesRequestBuilder<JsonInput, JsonOutput> extends AbstractRequestBuilderJsonOutput<ClusterStateRequest, ClusterStateResponse, JsonInput, JsonOutput> {

    public GetAliasesIndicesRequestBuilder(Client client, JsonToString<JsonInput> jsonToString, StringToJson<JsonOutput> stringToJson) {
        super(client, new ClusterStateRequest(), jsonToString, stringToJson);
        this.request.filterRoutingTable(true).filterNodes(true).listenerThreaded(false);
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.