Interface ESClient

    • Method Detail

      • waitForYellowStatus

        boolean waitForYellowStatus​(String[] indexNames,
                                    int timeoutSecond)
      • getHealthStatus

        org.elasticsearch.cluster.health.ClusterHealthStatus getHealthStatus​(String[] indexNames)
      • refresh

        void refresh​(String indexName)
      • flush

        void flush​(String indexName)
      • optimize

        void optimize​(String indexName)
      • indexExists

        boolean indexExists​(String indexName)
      • mappingExists

        boolean mappingExists​(String indexName,
                              String type)
      • deleteIndex

        void deleteIndex​(String indexName,
                         int timeoutSecond)
      • createIndex

        void createIndex​(String indexName,
                         String jsonSettings)
      • createMapping

        void createMapping​(String indexName,
                           String type,
                           String jsonMapping)
      • getMapping

        String getMapping​(String indexName)
        Returns the mapping from elastic, exposed for testing purposes
        Since:
        2021.17
      • getNodesInfo

        String getNodesInfo()
      • getNodesStats

        String getNodesStats()
      • aliasExists

        boolean aliasExists​(String aliasName)
      • getFirstIndexForAlias

        String getFirstIndexForAlias​(String aliasName)
        Returns the name of the index referenced by the alias. Returns null if the alias does not exists.
      • updateAlias

        void updateAlias​(String aliasName,
                         String indexName)
      • bulk

        org.elasticsearch.action.bulk.BulkResponse bulk​(org.elasticsearch.action.bulk.BulkRequest request)
      • delete

        org.elasticsearch.action.delete.DeleteResponse delete​(org.elasticsearch.action.delete.DeleteRequest request)
      • search

        org.elasticsearch.action.search.SearchResponse search​(org.elasticsearch.action.search.SearchRequest request)
      • searchScroll

        org.elasticsearch.action.search.SearchResponse searchScroll​(org.elasticsearch.action.search.SearchScrollRequest request)
      • get

        org.elasticsearch.action.get.GetResponse get​(org.elasticsearch.action.get.GetRequest request)
      • index

        org.elasticsearch.action.index.IndexResponse index​(org.elasticsearch.action.index.IndexRequest request)
        Performs the indexing request.
        Throws:
        ConcurrentUpdateException - if a more recent version of the document exits.
      • clearScroll

        org.elasticsearch.action.search.ClearScrollResponse clearScroll​(org.elasticsearch.action.search.ClearScrollRequest request)
      • bulkProcessorBuilder

        org.elasticsearch.action.bulk.BulkProcessor.Builder bulkProcessorBuilder​(org.elasticsearch.action.bulk.BulkProcessor.Listener listener)
        Creates an elasticsearch BulkProcessor builder.
        Since:
        10.3