Examples of ClusterStateRequest

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

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

    public ClusterStateRequestBuilder(Client client, JsonToString<JsonInput> jsonToString, StringToJson<JsonOutput> stringToJson) {
        super(client, new ClusterStateRequest(), jsonToString, stringToJson);
    }
View Full Code Here

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

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

    private String name;

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

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

82
83
84
85
86
87
88
89
90
91
92
            // TODO: what if queries goes to the old index while we reindexed?
            // now reindex
       
            if(type.equals("*")) {

                IndexMetaData indexData = client.admin().cluster().state(new ClusterStateRequest()).
                        actionGet().getState().metaData().indices().get(searchIndexName);
                Settings searchIndexSettings = indexData.settings();

                for(ObjectCursor<String> mapKeyCursor : indexData.mappings().keys()) {
                    reindexAction.handleRequest(request, channel, mapKeyCursor.value, true);
View Full Code Here

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

130
131
132
133
134
135
136
137
138
139
140
    /**
     * Creates a new index out of the settings from the old index.
     */
    private void createIdenticalIndex(String oldIndex, String type,
            String newIndex, int newIndexShards) throws IOException {
        IndexMetaData indexData = client.admin().cluster().state(new ClusterStateRequest()).
                actionGet().getState().metaData().indices().get(oldIndex);
        Settings searchIndexSettings = indexData.settings();
        ImmutableSettings.Builder settingBuilder = ImmutableSettings.settingsBuilder().put(searchIndexSettings);
        if (newIndexShards > 0)
            settingBuilder.put("index.number_of_shards", newIndexShards);
View Full Code Here

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

159
160
161
162
163
164
165
166
167
168
169
    }

    private void copyAliases(RestRequest request) {
        String index = request.param("index");
        String searchIndexName = request.param("searchIndex");
        IndexMetaData meta = client.admin().cluster().state(new ClusterStateRequest()).
                actionGet().getState().metaData().index(searchIndexName);
        IndicesAliasesRequest aReq = new IndicesAliasesRequest();
        boolean empty = true;
        if(meta != null && meta.aliases() != null) {
            for (ObjectCursor<String> oldAliasCursor : meta.aliases().keys() ) {
View Full Code Here

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

338
339
340
341
342
343
344
345
346
347
348
     
      // check the main index has the "collection" alias - if not then rebuild everything

      if (!bPingMainIndexFailed && (null == _aliasInfo)) {
        ElasticSearchManager docIndex = ElasticSearchManager.getIndex(DocumentPojoIndexMap.globalDocumentIndex_);
        ClusterStateResponse clusterState = docIndex.getRawClient().admin().cluster().state(new ClusterStateRequest()).actionGet();
        _aliasInfo = CrossVersionImmutableMapOfImmutableMaps.getAliases(clusterState.getState().getMetaData());
        if (!_aliasInfo.containsKey(DocumentPojoIndexMap.globalDocumentIndexCollection_)) {
          bRebuildDocsIndex = true;
        }
      } //TESTED
View Full Code Here

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

602
603
604
605
606
607
608
609
610
611
612
        // (just something that's guaranteed to exist)

      String stashedIndex = "recs_" + communityId.toString();
      String liveIndicesPrefix = "recs_t_" + communityId.toString();
     
      ClusterStateResponse clusterState = indexMgr.getRawClient().admin().cluster().state(new ClusterStateRequest()).actionGet();
      String indices[] = clusterState.getState().getMetaData().getConcreteAllOpenIndices();
      for (String index: indices) {
        if (index.startsWith(stashedIndex) || index.startsWith(liveIndicesPrefix)) {
          ElasticSearchManager.getIndex(index).deleteMe();
        }
View Full Code Here

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

862
863
864
865
866
867
868
869
870
871
        .execute().actionGet().isAcknowledged();
  }

  @Override
  public Set<String> queryForAlias(String indexName) {
    ClusterStateRequest clusterStateRequest = Requests.clusterStateRequest()
        .routingTable(true).nodes(true).indices(indexName);
    Iterator<String> iterator = client.admin().cluster().state(clusterStateRequest).actionGet().getState().getMetaData().aliases().keysIt();
    return newHashSet(iterator);
  }
View Full Code Here

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

109
110
111
112
113
114
115
116
117
118
119
     * @param index the name of the index
     * @return the index mapping as String
     * @throws IOException
     */
    protected String getIndexMapping(String index) throws IOException {
        ClusterStateRequest request = Requests.clusterStateRequest()
                .routingTable(false)
                .nodes(false)
                .metaData(true)
                .indices(index);
        ClusterStateResponse response = client().admin().cluster().state(request)
View Full Code Here

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

138
139
140
141
142
143
144
145
146
147
148
     * @param index the name of the index
     * @return the IndexSettings as JSON String
     * @throws IOException
     */
    protected String getIndexSettings(String index) throws IOException {
        ClusterStateRequest request = Requests.clusterStateRequest()
                .routingTable(false)
                .nodes(false)
                .metaData(true)
                .indices(index);
        ClusterStateResponse response = client().admin().cluster().state(request)
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.