public EsIndexBolt(EsConfig esConfig) {
        this(esConfig, new DefaultEsTupleMapper());
    }
@Test
    public void testEsIndexBolt() throws IOException {
        Tuple tuple = createTestTuple(index, type);

        bolt.execute(tuple);

        verify(outputCollector).ack(tuple);

        RestHighLevelClient client =  EsTestUtil.getRestHighLevelClient(node);
        RefreshRequest request = new RefreshRequest(index);
        client.indices().refresh(request, RequestOptions.DEFAULT);

        SearchRequest searchRequest = new SearchRequest(index);
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        searchSourceBuilder.query(new TermQueryBuilder("_type", type));
        searchSourceBuilder.size(0);
        searchRequest.source(searchSourceBuilder);

        SearchResponse resp = client.search(searchRequest, RequestOptions.DEFAULT);

        assertEquals(1, resp.getHits().getTotalHits());
    }