import java.net.InetAddress; import java.net.UnknownHostException; import org.elasticsearch.action.bulk.BulkRequestBuilder; import org.elasticsearch.action.bulk.BulkResponse; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.client.transport.TransportClient; import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.transport.InetSocketTransportAddress; import org.elasticsearch.transport.client.PreBuiltTransportClient; import java.lang.*; public class ESClientTest { public static void main(String[] args) throws UnknownHostException { Settings settings = Settings.builder().put("client.transport.sniff", true).build(); TransportClient transportClient = new PreBuiltTransportClient(settings) .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("10.178.209.160"), 9300)); String json = "{" + ""user":"kimchy"," + ""postDate":"2013-01-30"," + ""message":"trying out Elasticsearch"" + "}"; /* * IndexResponse response = transportClient.prepareIndex("twitter", * "tweet").setSource(json).execute().actionGet(); * System.out.println(response.toString()); */ BulkRequestBuilder bulkRequest = transportClient.prepareBulk(); bulkRequest.add(transportClient.prepareIndex("twitter", "tweet", "1").setSource(json)); long t1 = System.currentTimeMillis(); BulkResponse response1 = bulkRequest.get(); System.out.println(System.currentTimeMillis() - t1); if (response1.hasFailures()) { System.err.println(response1.buildFailureMessage()); } else { System.out.println( "Bulk indexing succeeded." + response1.toString() + " time:" + response1.getTookInMillis()); } transportClient.close(); } }