Create index in Elastic Search by Java API

Question

I used following code for creating index in Elastic Search, Default JAVA API:

Settings settings = ImmutableSettings.settingsBuilder().put("cluster.name", "myClusterName").put("client.transport.sniff", true).build();
Client client = new TransportClient(settings).addTransportAddress(new InetSocketTransportAddress("localhost", 9200));
CreateIndexRequestBuilder createIndexRequestBuilder = client.admin().indices().prepareCreate("test1");
CreateIndexResponse response = createIndexRequestBuilder.execute().actionGet();
System.out.println(response.isAcknowledged());

REST Service:

HttpURLConnection con = null;
try
{
    String url = "http://localhost:9200/test2";

    URL resturl = new URL(url);
    con = (HttpURLConnection) resturl.openConnection();

    con.setDoOutput(true);
    con.setRequestMethod("PUT");
    BufferedReader in = null;
    try
    {
        if (con.getInputStream() != null)
        {
            in = new BufferedReader(new InputStreamReader(con.getInputStream()));
        }
    }
    catch (IOException e)
    {
        if (con.getErrorStream() != null)
        {
            in = new BufferedReader(new InputStreamReader(con.getErrorStream()));
        }
    }
    if (in == null)
    {
        throw new Exception("Unable to read response from server");
    }
    StringBuffer decodedString = new StringBuffer();
    String line;
    while ((line = in.readLine()) != null)
    {
        decodedString.append(line);
    }
    in.close();
    System.out.println("4");
    Integer responseCode = con.getResponseCode();
    System.out.println(responseCode);
}
catch (Exception ex)
{
    ex.printStackTrace();
}
finally
{
    if (con != null)
    {
        con.disconnect();
    }
}

By using REST API, I am able to create index. By default JAVA API, I am getting the following Exception.

org.elasticsearch.client.transport.NoNodeAvailableException: No node available
at org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:202)
at org.elasticsearch.client.transport.support.InternalTransportIndicesAdminClient.execute(InternalTransportIndicesAdminClient.java:85)
at org.elasticsearch.client.support.AbstractIndicesAdminClient.create(AbstractIndicesAdminClient.java:200)
at org.elasticsearch.action.admin.indices.create.CreateIndexRequestBuilder.doExecute(CreateIndexRequestBuilder.java:206)
at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:62)
at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:57)
at ElasticSearch.createIndex(ElasticSearch.java:121)
at ElasticSearch.main(ElasticSearch.java:157)

Please guide me where I made mistake. Thanks in advance

nboire · Accepted Answer · 2013-05-20 12:35:13Z

10

The port for TransportClient(via java API) is different than Http By default, transportClient port is 9300

answered May 20, 2013 at 12:35

nboire

3122 silver badges3 bronze badges

Sign up to request clarification or add additional context in comments.

2 Comments

Ramaraj Karuppusamy Over a year ago

Thanks for your answer. Still I am getting the same exception.

Ramaraj Karuppusamy Over a year ago

It works fine now. I made a small mistake as I used 9300. But in config I updated port number.

rsilva4 · Accepted Answer · 2014-11-18 11:52:13Z

10

With replicas and shards settings:

Settings indexSettings = ImmutableSettings.settingsBuilder()
                 .put("number_of_shards", 1)
                 .put("number_of_replicas", 1)
                 .build();
CreateIndexRequest indexRequest = new CreateIndexRequest(index, indexSettings);
client.admin().indices().create(indexRequest).actionGet();

answered Nov 18, 2014 at 11:52

rsilva4

1,9551 gold badge24 silver badges40 bronze badges

1 Comment

Reda Over a year ago

Thanks :), nb : the class ImmutableSettings is removed: for the newer version, use Settings.builder(). For more info : stackoverflow.com/questions/33115504/…

Marcus Granström · Accepted Answer · 2013-05-20 12:45:05Z

6

Given that you have you client shouldn't you be able to do this then:

CreateIndexResponse createResponse = client.admin().indices().create(createIndexRequest("test1")).actionGet();

answered May 20, 2013 at 12:45

Marcus Granström

18k1 gold badge24 silver badges21 bronze badges

1 Comment

Jakub Kotowski Over a year ago

I would just add that the createIndexRequest method is Requests.createIndexRequest("test1")

dassum · Accepted Answer · 2019-07-01 12:14:44Z

Using JAVA High-Level Rest Client below code can be used to create Index.

 CreateIndexRequest request = new CreateIndexRequest("users");
        request.settings(Settings.builder()
                .put("index.number_of_shards", 3)
                .put("index.number_of_replicas", 2)
        );
        Map<String, Object> message = new HashMap<>();
        message.put("type", "text");   

        Map<String, Object> properties = new HashMap<>();
        properties.put("userId", message);
        properties.put("name", message);

        Map<String, Object> mapping = new HashMap<>();
        mapping.put("properties", properties);
        request.mapping(mapping);

        CreateIndexResponse indexResponse = client.indices().create(request, RequestOptions.DEFAULT);
        System.out.println("response id: "+indexResponse.index());

For further reference please read : https://www.elastic.co/guide/en/elasticsearch/client/java-rest/master/java-rest-high-create-index.html#java-rest-high-create-index

Collectives™ on Stack Overflow

Create index in Elastic Search by Java API

4 Answers 4

2 Comments

1 Comment

1 Comment

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

4 Answers 4

2 Comments

1 Comment

1 Comment

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related