public class DefaultContentsParserTest {
    static Suggester suggester;
    static OpenSearchRunner runner;
    DefaultContentsParser defaultContentsParser = new DefaultContentsParser();
    String[] supportedFields = new String[] { "content", "title" };
    String[] tagFieldNames = new String[] { "label", "virtual_host" };
    String roleFieldName = "role";

    @BeforeClass
    public static void beforeClass() throws Exception {

     * @param badWords The bad words array
     */
    public ContentIndexingContext(final String index, final String[] supportedFields, final String[] tagFieldNames,
            final String roleFieldName, final String langFieldName, final String[] badWords) {
        this.index = index;
        this.supportedFields = supportedFields;
        this.tagFieldNames = tagFieldNames;
        this.roleFieldName = roleFieldName;

     * @param supportedFields The supported fields
     * @param tagFieldNames The tag field names
     * @param roleFieldName The role field name
     * @param badWords The bad words array
     * @return The SuggestIndexResponse
     */
    public SuggestIndexResponse indexFromQueryLog(final String index, final QueryLog queryLog, final String[] supportedFields,

    static ReadingConverter defaultReadingConverter;
    static Normalizer defaultNormalizer;
    static final DefaultContentsParser parser = new DefaultContentsParser();
    static final String[] supportedFields = new String[] { "content", "title" };
    static final String[] tagFieldNames = new String[] { "label", "virtual_host" };
    static final String roleFieldName = "role";

    @BeforeClass

        this.client = client;
        this.settings = settings;
        this.indexName = indexName;
        supportedFields = settings.array().get(SuggestSettings.DefaultKeys.SUPPORTED_FIELDS);
        totalDocNum = getTotal();
    }

    @Override
    public synchronized Map<String, Object> read() {
        while (!isFinished.get() && queue.isEmpty()) {

        return this;
    }

    /**
     * Sets the supported fields.
     * @param supportedFields The supported fields.
     * @return This SuggestIndexer instance.
     */
    public SuggestIndexer setSupportedFields(final String[] supportedFields) {
        this.supportedFields = supportedFields;
        return this;
    }

    /**
     * Sets the tag field names.

     * Also updates the searchFieldSet for O(1) lookup performance.
     *
     * @param supportedFields array of field names that can be searched
     */
    public void setSearchFields(final String[] supportedFields) {
        searchFields = supportedFields;
        searchFieldSet = new HashSet<>();
        Collections.addAll(searchFieldSet, supportedFields);
    }

    /**
     * Gets the fields that can be used for faceted search.

     */
    public static class DefaultKeys {
        /** Index key. */
        public static final String INDEX = "index";
        /** Supported fields key. */
        public static final String SUPPORTED_FIELDS = "supportedFields";
        /** Tag field name key. */
        public static final String TAG_FIELD_NAME = "tagFieldName";
        /** Role field name key. */
        public static final String ROLE_FIELD_NAME = "roleFieldName";

    }

    @Test
    public void test_indexFromQueryString() throws Exception {
        SuggestSettings settings = suggester.settings();
        String field = settings.array().get(SuggestSettings.DefaultKeys.SUPPORTED_FIELDS)[0];

        SuggestIndexResponse indexResponse = suggester.indexer().indexFromQueryLog(new QueryLog(field + ":検索", null));
        assertEquals(1, indexResponse.getNumberOfInputDocs());

    public void test_indexFromDocumentWithMissingField() throws Exception {
        SuggestSettings settings = suggester.settings();
        String field = settings.array().get(SuggestSettings.DefaultKeys.SUPPORTED_FIELDS)[0];

        Map<String, Object>[] documents = new Map[1];
        documents[0] = new HashMap<>();
        // Document doesn't contain the supported field
        documents[0].put("other_field", "some content");