@@ -0,0 +1,2480 @@
+/*%0A * Licensed to Elastic Search and Shay Banon under one%0A * or more contributor license agreements.  See the NOTICE file%0A * distributed with this work for additional information%0A * regarding copyright ownership. Elastic Search licenses this%0A * file to you under the Apache License, Version 2.0 (the%0A * %22License%22); you may not use this file except in compliance%0A * with the License.  You may obtain a copy of the License at%0A *%0A *    http://www.apache.org/licenses/LICENSE-2.0%0A *%0A * Unless required by applicable law or agreed to in writing,%0A * software distributed under the License is distributed on an%0A * %22AS IS%22 BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY%0A * KIND, either express or implied.  See the License for the%0A * specific language governing permissions and limitations%0A * under the License.%0A */%0A%0Apackage org.elasticsearch.test.stress.manyindices;%0A%0Aimport org.elasticsearch.common.logging.ESLogger;%0Aimport org.elasticsearch.common.logging.Loggers;%0Aimport org.elasticsearch.common.settings.ImmutableSettings;%0Aimport org.elasticsearch.node.Node;%0Aimport org.elasticsearch.node.NodeBuilder;%0A%0Aimport java.util.Date;%0A%0A/**%0A * @author kimchy (shay.banon)%0A */%0Apublic class ManyIndicesRemoteStressTest %7B%0A%0A    private static final ESLogger logger = Loggers.getLogger(ManyIndicesRemoteStressTest.class);%0A%0A    public static void main(String%5B%5D args) throws Exception %7B%0A        System.setProperty(%22es.logger.prefix%22, %22%22);%0A%0A        int numberOfShards = 1;%0A        int numberOfReplicas = 1;%0A        int numberOfIndices = 1000;%0A        int numberOfDocs = 0;%0A%0A        Node node = NodeBuilder.nodeBuilder().client(true).node();%0A%0A        for (int i = 0; i %3C numberOfIndices; i++) %7B%0A            logger.info(%22START index %5B%7B%7D%5D ...%22, i);%0A            node.client().admin().indices().prepareCreate(%22index_%22 + i)%0A                    .setSettings(ImmutableSettings.settingsBuilder().put(%22index.number_of_shards%22, numberOfShards).put(%22index.number_of_replicas%22, numberOfReplicas))%0A                    .execute().actionGet();%0A%0A            for (int j = 0; j %3C numberOfDocs; j++) %7B%0A                node.client().prepareIndex(%22index_%22 + i, %22type%22).setSource(%22field1%22, %22test%22, %22field2%22, 2, %22field3%22, new Date()).execute().actionGet();%0A            %7D%0A            logger.info(%22DONE  index %5B%7B%7D%5D%22, i);%0A        %7D%0A%0A        node.client().admin().indices().prepareGatewaySnapshot().execute().actionGet();%0A%0A        logger.info(%22closing node...%22);%0A        node.close();%0A        logger.info(%22node closed%22);%0A    %7D%0A%7D%0A

add remote many indices creation test