esmapsample.java

    public String insert(@PathVariable final String id) throws UnknownHostException {
        final String indexName = "hotels";
        final String documentType = "tweet";
//        TransportClient client = new PreBuiltTransportClient(Settings.EMPTY)
//                .addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"), 9300));
//        System.out.println(client.connectedNodes());
        try {
            final IndicesExistsResponse res = client.admin().indices().prepareExists(indexName).execute().actionGet();
            if (!res.isExists()) {
                System.out.println("CREATE INDEX");
                final CreateIndexRequestBuilder createIndexRequestBuilder = client.admin().indices().prepareCreate(indexName);
                XContentBuilder mappingBuilder = jsonBuilder().startObject().
                        startObject("hotel").startObject("properties").
                        startObject("name").field("type", "text").endObject()
                        .startObject("name_suggest").field("type", "completion").endObject()
                        .endObject().endObject().endObject();

                System.out.println(mappingBuilder.string());

                createIndexRequestBuilder.addMapping("hotel", mappingBuilder);
//            createIndexRequestBuilder.setSource(jsonBuilder()
//                    .startObject()
//                    .field("name", "untitled")
//                    .endObject());
                createIndexRequestBuilder.execute().actionGet();
//                final DeleteIndexRequestBuilder delIdx = client.admin().indices().prepareDelete(indexName);
//                delIdx.execute().actionGet();
            }



            final IndexRequestBuilder indexRequestBuilder = client.prepareIndex(indexName, "hotel", id);

            indexRequestBuilder.setSource(jsonBuilder()
                    .startObject()
                    .field("name", "Courtyard by Marriot Munich City")
                    .field("name_suggest", "Courtyard by Marriot Munich City")
                    .endObject());

            return indexRequestBuilder.execute().actionGet().getResult().toString();

//            IndexResponse response = client.prepareIndex("event", "id", id)
//                    .setSource(jsonBuilder()
//                            .startObject()
//                            .field("name", "untitled")
//                            .field("id", "67")
//                            .endObject()).get();
//            return response.getResult().toString();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return null;
    }