private FesenClient fesenClient;

    private OpenSearchRunner runner;

    @Override
    protected String prepareConfigFile() {
        return "app.xml";
    }

    @Override
    protected boolean isUseOneTimeContainer() {
        return true;
    }

    @Override
    public void setUp() throws Exception {
        // create runner instance
        runner = new OpenSearchRunner();
        // create ES nodes

     *
     * @param elevateWord the elevate word entity to store
     */
    public void store(final ElevateWord elevateWord) {
        final boolean isNew = elevateWord.getId() == null;
        final String[] labelTypeIds = elevateWord.getLabelTypeIds();

        elevateWordBhv.insertOrUpdate(elevateWord, op -> {
            op.setRefreshPolicy(Constants.TRUE);

   *
   * @param string a string reference to check
   * @return {@code true} if the string is null or is the empty string
   */
  public static boolean isNullOrEmpty(@Nullable String string) {
    return Platform.stringIsNullOrEmpty(string);
  }

  /**
   * Returns a string, of length at least {@code minLength}, consisting of {@code string} prepended

     * @param url the URL to be checked for crawlability
     * @return {@code true} if the URL is crawlable; {@code false} if it matches the exclusion pattern
     */
    protected boolean isUrlCrawlable(final DataStoreParams paramMap, final String url) {
        if (paramMap.containsKey(URL_EXCLUDE_PATTERN)) {
            if (paramMap.get(URL_EXCLUDE_PATTERN) instanceof final String value) {

     * same {@code GenericDeclaration}.
     */
    boolean equalsType(Type type) {
      if (type instanceof TypeVariable) {
        return equalsTypeVariable((TypeVariable<?>) type);
      } else {
        return false;
      }
    }

    private boolean equalsTypeVariable(TypeVariable<?> that) {
      return var.getGenericDeclaration().equals(that.getGenericDeclaration())

    String password;
    /** The ANSI password hash */
    byte[] ansiHash;
    /** The Unicode password hash */
    byte[] unicodeHash;
    /** Flag indicating if hashes are externally provided */
    boolean hashesExternal = false;
    /** The client challenge for NTLM authentication */
    byte[] clientChallenge = null;
    /** The server challenge for NTLM authentication */
    byte[] challenge = null;

    /**

        return scheduledJobBhv.selectPage(cb -> {
            cb.fetchFirst(fessConfig.getPageScheduledJobMaxFetchSizeAsInteger());
            cb.query().setAvailable_Equal(Boolean.TRUE);
            cb.query().setUpdatedTime_GreaterThan(updateTime);
        });
    }

    /**
     * Gets a scheduled job by its ID.
     * @param id The ID of the scheduled job.

  /**
   * Returns the encoded media type, like "text/plain; charset=utf-8", appropriate for use in a
   * Content-Type header.
   */
  override fun toString(): String = mediaType

  override fun equals(other: Any?): Boolean = other is MediaType && other.mediaType == mediaType

  override fun hashCode(): Int = mediaType.hashCode()

  companion object {
    private const val TOKEN = "([a-zA-Z0-9-!#$%&'*+.^_`{|}~]+)"

        itemInfo,
        unrelatedInfo,
        !equivalence.equivalent(itemInfo.value, unrelatedInfo.value));
  }

  private void assertWithTemplate(String template, Item<T> item, Item<T> other, boolean condition) {
    if (!condition) {
      throw new AssertionFailedError(
          template
              .replace("$RELATIONSHIP", relationshipName)
              .replace("$HASH", hashName)

    String line;
    while ((line = r.readLine()) != null) {
      lines.add(line);
    }
    r.close();
    return lines;
  }

  private static List<String> readUsingReader(String input, int chunk, boolean asReader)
      throws IOException {
    Readable readable =
        asReader ? getChunkedReader(input, chunk) : getChunkedReadable(input, chunk);
    LineReader r = new LineReader(readable);