.setSource(item.getUpdatedSource(getResponse.getSourceAsMap()));
                bulkRequestBuilder.add(indexRequestBuilder);
            } else {
                final IndexRequestBuilder indexRequestBuilder = new IndexRequestBuilder(client, IndexAction.INSTANCE, index);
                indexRequestBuilder.setId(item.getId()).setOpType(IndexRequest.OpType.INDEX).setSource(item.getSource());

        assertNotNull(map.get(FieldNames.KINDS));
        assertNotNull(map.get(FieldNames.TIMESTAMP));
    }

    @Test
    public void testGetSource() {
        // Test getSource method
        String[] text = { "source", "test" };
        String[][] readings = { { "source" }, { "test" } };
        String[] fields = { "field1" };
        String[] tags = { "tag1" };

        if (!getResponse.isExists()) {
            return null;
        }
        final Map<String, Object> map = getResponse.getSource();
        return map.get(key);
    }

    /**
     * Retrieves a setting value as a String.
     * @param key The key of the setting.
     * @param defaultValue The default value if the setting is not found.

        final GetResponse response = getClient().get(c -> c.prepareGet().setIndex(index).setId(id).execute());
        if (response.isExists()) {
            final Map<String, Object> source = response.getSource();
            final T bean = BeanUtil.copyMapToNewBean(source, clazz, option -> {
                option.converter(new EsTimestampConverter(), timestampFields).excludeWhitespace();

     */
    public String getId() {
        return id;
    }

    /**
     * Returns the source map of the suggest item.
     * @return The source map.
     */
    public Map<String, Object> getSource() {
        final Map<String, Object> map = new HashMap<>();
        map.put(FieldNames.TEXT, text);

        for (int i = 0; i < readings.length; i++) {

            IndexRequestBuilder indexRequestBuilder = new IndexRequestBuilder(client, IndexAction.INSTANCE);
            indexRequestBuilder.setIndex(indexName).setId(String.valueOf(i)).setCreate(true).setSource(source);
            bulkRequestBuilder.add(indexRequestBuilder);
        }
        bulkRequestBuilder.execute().actionGet();
        runner.refresh();
    }

    }

    @Test
    public void testDeleteByQuery() {
        // Create test data
        client.prepareIndex().setIndex(TEST_INDEX).setId("1").setSource("field", "value1").execute().actionGet();
        client.prepareIndex().setIndex(TEST_INDEX).setId("2").setSource("field", "value2").execute().actionGet();
        client.admin().indices().prepareRefresh(TEST_INDEX).execute().actionGet();

        // Delete by query

        // Store analyzer mappings
        client.prepareIndex()
                .setIndex(SUGGEST_INDEX)
                .setId("analyzer_settings")
                .setSource(XContentFactory.jsonBuilder()
                        .startObject()
                        .startObject("analyzer")
                        .field("reading_analyzer", "test_reading_analyzer")

        runner.client()
                .prepareIndex()
                .setIndex(suggester.settings().analyzer().getAnalyzerSettingsIndexName())
                .setSource(analyzerMapping)
                .setRefreshPolicy(WriteRequest.RefreshPolicy.WAIT_UNTIL)
                .execute()
                .actionGet();
        suggester.settings().analyzer().init();

            }
            if (empty) {
                client.admin()
                        .indices()
                        .preparePutMapping(actualIndex)
                        .setSource(XContentFactory.jsonBuilder()
                                .startObject()
                                .startObject("properties")
                                .startObject(FieldNames.ARRAY_KEY)