keywordPath = environment.configDir().resolve(path);
        } else {
            keywordPath = null;
        }

        reloadInterval = settings.getAsTime("reload_interval", TimeValue.timeValueMinutes(1)).getMillis();
    }

    @Override
    public TokenStream create(final TokenStream tokenStream) {
        if (keywordPath == null) {
            return tokenStream;
        }

        } else {
            stopwordPath = null;
        }

        ignoreCase = settings.getAsBoolean("ignore_case", false);
        reloadInterval = settings.getAsTime("reload_interval", TimeValue.timeValueMinutes(1)).getMillis();
    }

    @Override
    public TokenStream create(final TokenStream tokenStream) {
        if (stopwordPath == null) {
            return tokenStream;
        }

                    throw new IllegalArgumentException("Failed to read " + filePath, e);
                }

                reloadInterval = settings.getAsTime("reload_interval", TimeValue.timeValueMinutes(1)).getMillis();

            } else {
                reader = Analysis.getReaderFromFile(env, settings, "synonyms_path");
            }
        } else {
            reader = new StringReader("");

     */
    private volatile boolean connected;

    /**
     * Scroll for delete operations.
     */
    protected Scroll scrollForDelete = new Scroll(TimeValue.timeValueMinutes(1));

    /**
     * Size for delete operations.
     */
    protected int sizeForDelete = 10;

    /**
     * Retry interval in milliseconds.
     */