try {
            final XContentBuilder builder = JsonXContent.contentBuilder().map(source);
            builder.flush();
            client.prepareUpdate()
                    .setIndex(actualIndex)
                    .setId(id)
                    .setDocAsUpsert(true)
                    .setDoc(builder)
                    .execute()
                    .actionGet(settings.getIndexTimeout());

	exit
fi

# Compare the difference of the list of disks and their location, with the below expected output
diff <(./mc admin info minio1 --json | jq -r '.info.servers[].drives[] | "\(.pool_index),\(.set_index),\(.disk_index) \(.endpoint)"' | sort) <(
	cat <<EOF
0,0,0 http://localhost:9001/tmp/xl/node9001/mnt/disk1
0,0,1 http://localhost:9002/tmp/xl/node9002/mnt/disk1
0,0,2 http://localhost:9001/tmp/xl/node9001/mnt/disk2

            source.put("field1", "test" + i);
            source.put("field2", 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();
    }

        SuggestUtil.getAsList(123);
    }

    @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();

                    for (final SearchHit searchHit : searchHits) {
                        final UpdateRequestBuilder updateRequest =
                                c.prepareUpdate().setIndex(index).setId(searchHit.getId()).setDoc(SESSION_ID, newSessionId);
                        builder.add(updateRequest);
                    }

                    return builder.execute();
                });

        storeAnalyzerSettings();
    }

    private static void storeAnalyzerSettings() throws Exception {
        // Store analyzer mappings
        client.prepareIndex()
                .setIndex(SUGGEST_INDEX)
                .setId("analyzer_settings")
                .setSource(XContentFactory.jsonBuilder()
                        .startObject()
                        .startObject("analyzer")

        public void refresh() {
            // Mock implementation
        }

        public void createIndexIfNothing() {
            // Mock implementation
        }

        public String getIndex() {
            return "fess.suggest";
        }

        public long getAllWordsNum() {
            return 100L;
        }

        public long getDocumentWordsNum() {
            return 50L;

// but not written in all disks (having quorum)
type PartialOperation struct {
	Bucket              string
	Object              string
	VersionID           string
	Versions            []byte
	SetIndex, PoolIndex int
	Queued              time.Time
	BitrotScan          bool
}

// mrfState sncapsulates all the information
// related to the global background MRF.
type mrfState struct {
	opCh chan PartialOperation

        // Set up lenient stubs for common operations to avoid unnecessary stubbing exceptions
        lenient().when(mockNdrBuffer.getIndex()).thenReturn(0);
        lenient().when(mockDeferredNdrBuffer.getIndex()).thenReturn(0);
        // Mock the index field access
        mockDeferredNdrBuffer.index = 0;
    }

    @Test
    void testGetSyntax() {

        final ParsePosition pos = new ParsePosition(0);
        final Date date = format.parse(str, pos);
        if (date == null) {
            return null;
        }
        final int index = pos.getIndex();
        if (index == 0) {
            return null;
        }
        if (index < str.length()) {
            return null;
        }
        return date;
    }

    /**