Examples of routing()

Examples of org.elasticsearch.cluster.metadata.AliasAction.routing()

843
844
845
846
847
848
849
850
851
852
853
    if (query.getFilterBuilder() != null) {
      aliasAction.filter(query.getFilterBuilder());
    } else if (query.getFilter() != null) {
      aliasAction.filter(query.getFilter());
    } else if (isNotBlank(query.getRouting())) {
      aliasAction.routing(query.getRouting());
    } else if (isNotBlank(query.getSearchRouting())) {
      aliasAction.searchRouting(query.getSearchRouting());
    } else if (isNotBlank(query.getIndexRouting())) {
      aliasAction.indexRouting(query.getIndexRouting());
    }
View Full Code Here

Examples of org.elasticsearch.cluster.metadata.AliasAction.routing()

356
357
358
359
360
361
362
363
364
365
366
   * @return true if acknowledged
   */
  public static boolean addIndexAlias(String indexName, String alias, boolean setRouting) {
    AliasAction act = new AliasAction(AliasAction.Type.ADD, indexName, alias);
    if (setRouting) {
      act.routing(alias);
      act.filter(FilterBuilders.termFilter(Config._APPID, alias));
    }
    return getClient().admin().indices().prepareAliases().addAliasAction(act).
        execute().actionGet().isAcknowledged();
  }
View Full Code Here

Examples of org.elasticsearch.cluster.metadata.MappingMetaData.routing()

84
85
86
87
88
89
90
91
92
93
94
        }
        assertThat(health.timedOut(), equalTo(false));

        logger.info("--> verify meta _routing required exists");
        MappingMetaData mappingMd = client("node1").admin().cluster().prepareState().execute().actionGet().state().metaData().index("test").mapping("type1");
        assertThat(mappingMd.routing().required(), equalTo(true));

        logger.info("--> close node");
        closeNode("node1");

        logger.info("--> starting node again...");
View Full Code Here

Examples of org.elasticsearch.cluster.metadata.MappingMetaData.routing()

102
103
104
105
106
107
108
109
110
111
112
        }
        assertThat(health.timedOut(), equalTo(false));

        logger.info("--> verify meta _routing required exists");
        mappingMd = client("node1").admin().cluster().prepareState().execute().actionGet().state().metaData().index("test").mapping("type1");
        assertThat(mappingMd.routing().required(), equalTo(true));
    }

    @Test public void testSimpleOpenClose() throws Exception {
        logger.info("--> cleaning nodes");
        buildNode("node1", settingsBuilder().put("gateway.type", "local").build());
View Full Code Here

Examples of org.elasticsearch.cluster.metadata.MappingMetaData.routing()

114
115
116
117
118
119
120
121
122
123
124
                IndexRequest indexRequest = (IndexRequest) item.request();
                try {

                    // validate, if routing is required, that we got routing
                    MappingMetaData mappingMd = clusterState.metaData().index(request.index()).mapping(indexRequest.type());
                    if (mappingMd != null && mappingMd.routing().required()) {
                        if (indexRequest.routing() == null) {
                            throw new RoutingMissingException(indexRequest.index(), indexRequest.type(), indexRequest.id());
                        }
                    }
View Full Code Here

Examples of org.elasticsearch.cluster.metadata.MappingMetaData.routing()

181
182
183
184
185
186
187
188
189
190
191
                }
                list.add(new BulkItemRequest(i, request));
            } else if (request instanceof DeleteRequest) {
                DeleteRequest deleteRequest = (DeleteRequest) request;
                MappingMetaData mappingMd = clusterState.metaData().index(deleteRequest.index()).mapping(deleteRequest.type());
                if (mappingMd != null && mappingMd.routing().required() && deleteRequest.routing() == null) {
                    // if routing is required, and no routing on the delete request, we need to broadcast it....
                    GroupShardsIterator groupShards = clusterService.operationRouting().broadcastDeleteShards(clusterState, deleteRequest.index());
                    for (ShardIterator shardIt : groupShards) {
                        List<BulkItemRequest> list = requestsByShard.get(shardIt.shardId());
                        if (list == null) {
View Full Code Here

Examples of org.elasticsearch.cluster.metadata.MappingMetaData.routing()

98
99
100
101
102
103
104
105
106
107
108
        request.routing(clusterState.metaData().resolveIndexRouting(request.routing(), request.index()));
        request.index(clusterState.metaData().concreteIndex(request.index())); // we need to get the concrete index here...
        if (clusterState.metaData().hasIndex(request.index())) {
            // check if routing is required, if so, do a broadcast delete
            MappingMetaData mappingMd = clusterState.metaData().index(request.index()).mapping(request.type());
            if (mappingMd != null && mappingMd.routing().required()) {
                if (request.routing() == null) {
                    indexDeleteAction.execute(new IndexDeleteRequest(request), new ActionListener<IndexDeleteResponse>() {
                        @Override public void onResponse(IndexDeleteResponse indexDeleteResponse) {
                            // go over the response, see if we have found one, and the version if found
                            long version = 0;
View Full Code Here

Examples of org.elasticsearch.cluster.metadata.MappingMetaData.routing()

168
169
170
171
172
173
174
175
176
177
178
    @Override protected PrimaryResponse<IndexResponse> shardOperationOnPrimary(ClusterState clusterState, ShardOperationRequest shardRequest) {
        final IndexRequest request = shardRequest.request;

        // validate, if routing is required, that we got routing
        MappingMetaData mappingMd = clusterState.metaData().index(request.index()).mapping(request.type());
        if (mappingMd != null && mappingMd.routing().required()) {
            if (request.routing() == null) {
                throw new RoutingMissingException(request.index(), request.type(), request.id());
            }
        }
View Full Code Here

Examples of org.elasticsearch.cluster.metadata.MappingMetaData.routing()

73
74
75
76
77
78
79
80
81
82
83
        logger.info("--> waiting for yellow status");
        ensureYellow();

        logger.info("--> verify meta _routing required exists");
        MappingMetaData mappingMd = client().admin().cluster().prepareState().execute().actionGet().getState().metaData().index("test").mapping("type1");
        assertThat(mappingMd.routing().required(), equalTo(true));

        logger.info("--> restarting nodes...");
        internalCluster().fullRestart();

        logger.info("--> waiting for yellow status");
View Full Code Here

Examples of org.elasticsearch.cluster.metadata.MappingMetaData.routing()

83
84
85
86
87
88
89
90
91
92
93
        logger.info("--> waiting for yellow status");
        ensureYellow();

        logger.info("--> verify meta _routing required exists");
        mappingMd = client().admin().cluster().prepareState().execute().actionGet().getState().metaData().index("test").mapping("type1");
        assertThat(mappingMd.routing().required(), equalTo(true));
    }

    @Test
    public void testSimpleOpenClose() throws Exception {
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.