public static void bulkUpdateGoods(List<Goods> goods) throws IOException, InterruptedException, ExecutionException {

        Client client = null;

        try {

            client = TransportClient.builder().build()

                    .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("hadoop-slave4"), 9300));

        } catch (Exception e) {

            e.printStackTrace();

        }

        BulkRequestBuilder req = client.prepareBulk();

        for (Goods good : goods) {

            req.add(client.prepareIndex("smms", "goods", good.getId() + "")

                    .setSource(jsonBuilder().startObject().field("unit", good.getUnit()).field("price", good.getPrice())

                            .field("name", good.getName()).field("barcode", good.getBarCode()).endObject()));

        }

        BulkResponse res = req.execute().actionGet();

        if (res.hasFailures()) {

            System.out.println("Error");

        } else {

            System.out.println("Done");

        }

        client.close();

    }

}