}
                });

        assertNotNull(results);
        assertEquals(5, results.size());
    }

    private void createTestIndex() {
        if (!runner.indexExists(INDEX_NAME)) {
            runner.admin().indices().prepareCreate(INDEX_NAME).execute().actionGet();
        }
    }

    private void indexDocuments(int count) {
        for (int i = 0; i < count; i++) {