Elasticsearch Java API Index Document

Question

Downloaded .90.6, Unpacked, moved Elastic Search to /usr/share/elasticsearch (with chmod 777 -R permissions on centosx64 6.4), renamed cluster to somethingstupid and started server.
Installed plugins ESHead and ESBrowser b/c Im new and need it (am used to Solr's nice ui). This way I know the server is running too.
I can create an index via curl : curl -XPOST 'http://localhost:9200/testindex' and delete it too: curl -XDELETE 'http://localhost:9200/testindex'

When I try creating a new index and indexing a document of type article and viewing it via Java API, eclipse runs the code, shows basic logging in the console, and then closes with no errors. Also, inside my logs the latest line just shows that I have started up elastic search but nothing else. Its like the code isnt even reaching elastic search. No indexes or articles show up after I run the java api. What am I missing?

import java.util.Date;
import java.util.HashMap;
import java.util.Map;

import org.elasticsearch.client.Client;
import org.elasticsearch.node.Node;

import static org.elasticsearch.node.NodeBuilder.*;

public class PostES {

    public static void main (String args[]){
        PostES p = new PostES();
        p.postElasticSearch();
    }


    public static Map<String, Object> putJsonDocument(String title, String content, Date postDate, String author){

            Map<String, Object> jsonDocument = new HashMap<String, Object>();

            jsonDocument.put("title", title);
            jsonDocument.put("conten", content);
            jsonDocument.put("postDate", postDate);
            jsonDocument.put("author", author);

            return jsonDocument;
    }


    private void postElasticSearch(){

            Node node    = nodeBuilder().node();
            Client client   = node.client();

            client.prepareIndex("testindex", "article")
                      .setSource(putJsonDocument("Example Title",
                                                 "This description is so important. You don't even know!",
                                                 new Date(),
                                                 "J.R."))
                                                 .execute().actionGet();

            node.close();
        }


}

My Source: http://java.dzone.com/articles/elasticsearch-java-api. Everything else including the elastic documentation failed one way or another....(The method jsonBuilder() is undefined for the type PostES).

According to documentation I should be able to do this. But it does nothing either:

import static org.elasticsearch.node.NodeBuilder.nodeBuilder;

import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.Client;
import org.elasticsearch.node.Node;


public class TestPostMethod2 {

    public static void main(String[] args) {
        Node node = nodeBuilder().local(true).node();
        Client client = node.client();

            String json = 
                    "{\"user\":\"kimchy\"," +
                    "\"postDate\":\"2013-01-30\"," +
                    "\"message\":\"trying out Elastic Search\"}";              

            IndexResponse response = client.prepareIndex("testindex", "article")
                    .setSource(json)
                    .execute()
                    .actionGet();
    }

}

javanna · Accepted Answer · 2013-11-09 11:16:39Z

1

You need to specify your cluster name when creating a node and specify it is a client node, or use the transport client.

What you are currently doing in both cases is starting a new node that creates a new cluster with default name, while you would like to have a client node to join your existing cluster.

Node node = nodeBuilder().clusterName("somethingstupid").client(true).node();

answered Nov 9, 2013 at 11:16

javanna

60.4k14 gold badges147 silver badges125 bronze badges

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

Comments

Алексей · Accepted Answer · 2013-11-07 20:41:10Z

0

not sure if this is related, but when originally i were trying to connect to running ES cluster from eclipse i had to add this to the arguments of my tomcat:

-Delasticsearch -Des.path.home=/usr/local/opt/elasticsearch

where elasticsearch is the name that you have defined in elasticsearch.yml and of course the path where you have installed ES

answered Nov 7, 2013 at 20:41

Алексей

1,85712 silver badges15 bronze badges

2 Comments

Chris Over a year ago

Tomcat? I'm supposed to stick elastic search inside of a container? Man am I confused. WHY DO PEOPLE SAY THIS IS SO EASY TO GET STARTED ON? I must be a real imbecile...

Алексей Over a year ago

bah never mind, my bad. Node node = nodeBuilder().clusterName("somethingstupid").node(); Client client = node.client(); you need to specify your cluster name on connect if its different

Chris · Accepted Answer · 2013-11-08 16:27:58Z

1 way I can get the api to work is by not using it:

import java.io.BufferedReader;
import java.io.InputStreamReader;
import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;


public class PostHttpClient {

    public static void main(String[] args) {
        try{
        DefaultHttpClient httpClient = new DefaultHttpClient();
        HttpPost postRequest = new HttpPost(
            "http://localhost:9200/testindex/article");

        StringEntity input = new StringEntity("{\"name\":\"ES JAVA API WorkAround\",\"category\":\"Garbage\"}");
        input.setContentType("application/json");
        postRequest.setEntity(input);

        HttpResponse response = httpClient.execute(postRequest);

        if (response.getStatusLine().getStatusCode() != 201) {
            throw new RuntimeException("Failed : HTTP error code : "
                + response.getStatusLine().getStatusCode());
        }

        BufferedReader br = new BufferedReader(
                        new InputStreamReader((response.getEntity().getContent())));

        String output;
        System.out.println("Output from Server .... \n");
        while ((output = br.readLine()) != null) {
            System.out.println(output);
        }

        httpClient.getConnectionManager().shutdown();

      } catch (Exception e) {

        e.printStackTrace();

      } 

    }

}

isapir · Accepted Answer · 2014-04-29 18:41:36Z

Why not use the Transport Client with a java.util.Map?

import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.Client;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.transport.InetSocketTransportAddress;

import java.util.*;

public class Test {

    public static Client getTransportClient(String host, int port) {

        return new TransportClient()
                .addTransportAddress(new InetSocketTransportAddress(host, port));
    }

    public static IndexResponse doIndex(Client client, String index, String type, String id, Map<String, Object> data) {

        return client.prepareIndex(index, type, id)
                .setSource(data)
                .execute()
                .actionGet();
    }

    public static void main(String[] args) {

        Client client = getTransportClient("localhost", 9300);

        String index  = "twitter";
        String type   = "tweet";
        String id     = null;        // set id here if you want to

        Map<String, Object> data = new HashMap<String, Object>();
        data.put("text", "Posted from Java @ " + System.currentTimeMillis());
        data.put("user", "Igal");
        data.put("date", new Date());

        IndexResponse result = doIndex(client, index, type, id, data);

        System.out.println((result.isCreated() ? "created" : "updated") + " document " + result.getId() );

        client.close();
    }
}

ray · Accepted Answer · 2019-01-22 18:00:19Z

I would suggest anyone to use rest client(jest) instead of transport client, remember to add all dependencies specified in link-1 & link-2

replace "index_name" = with your index name

creating simple index and inserting data using java,

public void setData(String data)
{           
    try

    {
     // Construct a new Jest client according to configuration via factory
     JestClientFactory factory = new JestClientFactory();
     factory.setHttpClientConfig(new HttpClientConfig
                            .Builder("http://localhost:9200")
                            .multiThreaded(true)
                            .build());
     JestClient client = factory.getObject();

client.execute(new CreateIndex.Builder("index_name").build());



        String source = jsonBuilder()
                .startObject()
                .field("data", data)
                 //other data
                .endObject().string();
        System.out.println(source); // verify data

        Index index = new Index.Builder(source).index("index_name").type("_type").build();
        client.execute(index);


    }
    catch(IOException i)
    {
        i.printStackTrace();
    }
    catch(Exception e)
    {
        e.printStackTrace();
    }
 }

Collectives™ on Stack Overflow

Elasticsearch Java API Index Document

5 Answers 5

Comments

2 Comments

Comments

Comments

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

5 Answers 5

Comments

2 Comments

Comments

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Related