Package org.apache.tika.pipes.reporters.opensearch

Class OpenSearchPipesReporter

java.lang.Object
org.apache.tika.pipes.PipesReporter
org.apache.tika.pipes.reporters.opensearch.OpenSearchPipesReporter
All Implemented Interfaces:
Closeable, AutoCloseable, Initializable
public class OpenSearchPipesReporter extends PipesReporter implements Initializable
As of the 2.5.0 release, this is ALPHA version. There may be breaking changes in the future.

  • Field Details

    • DEFAULT_PARSE_TIME_KEY

      public static String DEFAULT_PARSE_TIME_KEY

    • DEFAULT_PARSE_STATUS_KEY

      public static String DEFAULT_PARSE_STATUS_KEY

    • DEFAULT_EXIT_VALUE_KEY

      public static String DEFAULT_EXIT_VALUE_KEY

  • Constructor Details

    • OpenSearchPipesReporter

      public OpenSearchPipesReporter()

  • Method Details

    • report

      public void report(FetchEmitTuple t, PipesResult result, long elapsed)
      Specified by:
      report in class PipesReporter

    • error

      public void error(Throwable t)
      Description copied from class: PipesReporter
      This is called if the process has crashed. Implementers should not rely on close() to be called after this.
      Specified by:
      error in class PipesReporter

    • error

      public void error(String msg)
      Description copied from class: PipesReporter
      This is called if the process has crashed. Implementers should not rely on close() to be called after this.
      Specified by:
      error in class PipesReporter

    • setConnectionTimeout

      @Field public void setConnectionTimeout(int connectionTimeout)

    • setSocketTimeout

      @Field public void setSocketTimeout(int socketTimeout)

    • setOpenSearchUrl

      @Field public void setOpenSearchUrl(String openSearchUrl)

    • setUserName

      @Field public void setUserName(String userName)

    • setPassword

      @Field public void setPassword(String password)

    • setAuthScheme

      @Field public void setAuthScheme(String authScheme)

    • setProxyHost

      @Field public void setProxyHost(String proxyHost)

    • setProxyPort

      @Field public void setProxyPort(int proxyPort)

    • setIncludeStatuses

      @Field public void setIncludeStatuses(List<String> statusList)

    • setExcludeStatuses

      @Field public void setExcludeStatuses(List<String> statusList)

    • setIncludeRouting

      @Field public void setIncludeRouting(boolean includeRouting)

    • setKeyPrefix

      @Field public void setKeyPrefix(String keyPrefix)
      This prefixes the keys before sending them to OpenSearch. For example, "pdfinfo_", would have this reporter sending "pdfinfo_status" and "pdfinfo_parse_time" to OpenSearch.
      Parameters:
      keyPrefix -

    • initialize

      public void initialize(Map<String,Param> params) throws TikaConfigException
      Specified by:
      initialize in interface Initializable
      Parameters:
      params - params to use for initialization
      Throws:
      TikaConfigException

    • checkInitialization

      public void checkInitialization(InitializableProblemHandler problemHandler) throws TikaConfigException
      Specified by:
      checkInitialization in interface Initializable
      Parameters:
      problemHandler - if there is a problem and no custom initializableProblemHandler has been configured via Initializable parameters, this is called to respond.
      Throws:
      TikaConfigException