assertNotNull(result);
        assertFalse(result.hasFailure());

        runner.refresh();

        GetResponse getResponse =
                runner.client().prepareGet().setIndex(suggester.getIndex()).setId(item.getId()).get(TimeValue.timeValueSeconds(30));
        assertTrue(getResponse.isExists());
    }

    @Test
    public void test_writeItemsWithUpdate() throws Exception {

    @Override
    public GetRequestBuilder prepareGet() {
        return client.prepareGet();
    }

    /**
     * Prepares a get request builder for a specific document.
     *
     * @param index the index name
     * @param id    the document ID
     * @return the get request builder
     */
    @Override
    public GetRequestBuilder prepareGet(final String index, final String id) {

        boolean doIndexCreate = false;
        boolean doCreate = false;
        try {
            final GetResponse getResponse =
                    client.prepareGet().setIndex(settingsIndexName).setId(settingsId).execute().actionGet(getSearchTimeout());

            if (!getResponse.isExists()) {
                doCreate = true;
            }