gistfile1.java

package org.elasticsearch.benchmark;

import org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse;
import org.elasticsearch.discovery.MasterNotDiscoveredException;
import org.elasticsearch.node.Node;

import static org.elasticsearch.common.settings.ImmutableSettings.*;
import static org.elasticsearch.node.NodeBuilder.*;

/**
 * @author kimchy (shay.banon)
 */
public class Main {

    public static void main(String[] args) throws InterruptedException {
        Node clientNode = nodeBuilder().settings(settingsBuilder().put("path.data", "data_client")).client(true).node();

        try {
            ClusterHealthResponse clusterHealthResponse = clientNode.client().admin().cluster().prepareHealth().execute().actionGet();
            System.out.println("Health: " + clusterHealthResponse.getStatus());
        } catch (MasterNotDiscoveredException e) {
            System.out.println("No master, this is what should happen...");
        }

        Node dataNode = nodeBuilder().settings(settingsBuilder().put("path.data", "data_node")).node();

        clientNode.client().admin().indices().prepareCreate("test").execute().actionGet();

        Thread.sleep(100000);
    }
}