public test() throws UnknownHostException {
    	Settings setting = Settings.builder()
                .put("cluster.name", "cluster1")
                .put("client.transport.sniff", true).build();
        this.client = new PreBuiltTransportClient(setting)
                .addTransportAddresses(new InetSocketTransportAddress(InetAddress.getByName(host), 9300),new InetSocketTransportAddress(InetAddress.getByName(host), 9301));
 }

public class restClientConnection {

	private HttpHost httpHost;
	private RestClient restClient;
	private static HttpHost httpHost2 = new HttpHost("localhost",9303,"http");
	
	public restClientConnection(String host, int port, String protocol) {
		
		this.httpHost = new HttpHost(host, port, protocol);
	}
	
	public RestClient connect() {
		
		this.restClient = RestClient.builder(this.httpHost,httpHost2).build();
		return this.restClient;
		
	}
}

 public String insertid(@PathVariable final String id) throws IOException {

        IndexResponse response = this.client.prepareIndex("person", "id", id)
                .setSource(jsonBuilder()
                        .startObject()
                        .field("fname", "shakeel")
                        .field("fplace", "bangalore" )
                        .field("fteamName", "R&D")
                        .endObject()
                )
                
                .get();
        return response.getResult().toString();
    }

public String insertpid(@PathVariable final String id) throws IOException {

        IndexResponse response = this.client.prepareIndex()
        		.setIndex("person")
        		.setType("id")
        		.setId(id)
                .setSource(jsonBuilder()
                        .startObject()
                        .field("fullname", "shakeel")
                        .field("age", "31" )
                        .field("qualification", "graduate")
                        .endObject()
                )
                
                .get();
        return response.getResult().toString();
    }

 public String update1(@PathVariable final String id) throws IOException {

        UpdateRequest updateRequest = new UpdateRequest();
        updateRequest.index("employee")
                .puttype("cluster.name", "cluster1"id")
                .put("client.transport.sniff", true).build();id(id)
          this.client = new PreBuiltTransportClient(setting)   .doc(jsonBuilder()
             .addTransportAddresses(new InetSocketTransportAddress(InetAddress.getByName(host), 9300),new InetSocketTransportAddress(InetAddress.getByName(host), 9301));  } 

public class restClientConnection {  	private HttpHost httpHost;
	private RestClient restClient;
	private static HttpHost httpHost2 = new HttpHost("localhost",9303,"http");
	
	public restClientConnection(String host, int port, String protocol) {
		
		this.httpHost = new HttpHost(host, port, protocol);
	}
	
	public RestClient connect() {
		
		this.restClient = RestClient.builder(this.httpHost,httpHost2).build();
		return this.restClient;
		
	}
}

public String explain1() throws IOException {
    	ExplainRequest explainRequest =       .doc(jsonBuilder()new ExplainRequest("person","id","123");
    	QueryBuilder queryBuilder           = QueryBuilders.matchQuery("lastname","khan");
    	explainRequest =  explainRequest.startObjectquery(queryBuilder);
    	ExplainResponse eResponse = client.explain(explainRequest).actionGet();
    	System.out.println(eResponse.getExplanation().getDescription());
           .field("gender", "male")return eResponse.getExplanation().getDescription();
    }

public String fieldcap() throws IOException {
    	FieldCapabilitiesRequest fRequest = new FieldCapabilitiesRequest();
    	fRequest.endObjectfields("name").indices("employee","person");
    	FieldCapabilitiesResponse fResponse   try {
        = client.fieldCaps(fRequest).actionGet();
   UpdateResponse updateResponse = this.client.update(updateRequest).get( 	System.out.println(fResponse.get().toString());
        return    System.out.println(updateResponse.status());
      fResponse.get().toString();
    }

 public String delete1(@PathVariable final String id) {

    return updateResponse.status().toString();   DeleteResponse deleteResponse = client.prepareDelete("employee",   } catch (InterruptedException | ExecutionException e) {
  "id", id).get();

        System.out.println(e(deleteResponse.getResult().toString());
        }
return deleteResponse.getResult().toString();
       return "Exception";
    }

 public String update1(@PathVariable final String id) throws IOException {

        UpdateRequest updateRequest = new UpdateRequest();
        updateRequest.index("employee")
                .type("id")
    }

public static void main(String[] args) throws IOException {
	 	// Demo the JestClient
        JestClient jestClient = .idjestClient(id);
		// Index a document from String
        ObjectMapper mapper = new .doc(jsonBuilderObjectMapper();
        JsonNode employeeJsonNode = mapper.createObjectNode()
            .startObject()    .put("name", "Michael  Pratt")
                 .fieldput("gendertitle", "maleJava Developer")
                .put("yearsOfService", 2)
      .endObject());         try {
  .set("skills", mapper.createArrayNode()
          UpdateResponse updateResponse = this.client.update(updateRequest).get();             System.out.println(updateResponse.status());.add("java")
            return updateResponse.status().toString();         } catch (InterruptedException | ExecutionException e) {.add("spring")
                System.out.println(e);         }.add("elasticsearch"));
         return "Exception";
    }jestClient.execute(new Index.Builder(employeeJsonNode.toString()).index("employees").build());
}

public static void main(String[] args) throws IOException {
	 	// Demo the JestClient
        JestClient jestClient =   .id("123")
                .doc(jsonBuilder()
 jestClient();
		// Update document
        employee.setYearsOfService(3);
        jestClient.execute(new Update.Builder(employee).index("employees").id("1").build());
}

public static void .startObject(main(String[] args) throws IOException {
	 	// Demo the JestClient
        JestClient jestClient       .field("gender", "male")
                        .endObject());= jestClient();
		// Read document by ID
        	UpdateResponseEmployee gResponsegetResult = clientjestClient.execute(UpdateAction.INSTANCE,updateRequest).actionGet();
    	System.out.println(gResponse.toString());
        return gResponse.toString();
    }