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();
    }

}