@Test
public void testSaveBulk() throws Exception {

    List<Document> documents = new Vector<Document>();
    for (int i = 0; i < 10; i++) {
        documents.add(new Document(UUID.randomUUID().toString(),
                System.currentTimeMillis(),
                mapper.valueToTree(Collections.singletonMap("TEST_NAME", "SINGLE_SAVE_TEST"))));
    }
    queryStore.save(TestUtils.TEST_TABLE_NAME, documents);
    for (Document document : documents) {
        GetResponse getResponse = elasticsearchServer
                .getClient()
                .prepareGet(ElasticsearchUtils.getCurrentIndex(TestUtils.TEST_TABLE_NAME, document.getTimestamp()),
                        ElasticsearchUtils.TYPE_NAME,
                        document.getId())
                .setFields("_timestamp").execute().actionGet();
        assertTrue("Id should exist in ES", getResponse.isExists());
        assertEquals("Id should match requestId", document.getId(), getResponse.getId());
        assertEquals("Timestamp should match request timestamp", document.getTimestamp(), getResponse.getField("_timestamp").getValue());
    }
}