Package org.codelibs.fess.es.client

Class FessEsClient

  • All Implemented Interfaces:
    Closeable, AutoCloseable, org.elasticsearch.client.Client, org.elasticsearch.client.ElasticsearchClient, org.elasticsearch.common.lease.Releasable
    public class FessEsClient
extends Object
implements org.elasticsearch.client.Client

    • Constructor Summary

      Constructors 
      Constructor Description
      FessEsClient()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void addAll​(String index, List<Map<String,​Object>> docList, BiConsumer<Map<String,​Object>,​org.elasticsearch.action.index.IndexRequestBuilder> options)  
      void addConfigFile​(String index, String path)  
      void addIndexConfig​(String path)  
      void addMapping​(String index, String docType, String indexName)  
      org.elasticsearch.client.AdminClient admin()  
      org.elasticsearch.action.ActionFuture<org.elasticsearch.action.bulk.BulkResponse> bulk​(org.elasticsearch.action.bulk.BulkRequest request)  
      void bulk​(org.elasticsearch.action.bulk.BulkRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.action.bulk.BulkResponse> listener)  
      org.elasticsearch.action.ActionFuture<org.elasticsearch.action.search.ClearScrollResponse> clearScroll​(org.elasticsearch.action.search.ClearScrollRequest request)  
      void clearScroll​(org.elasticsearch.action.search.ClearScrollRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.ClearScrollResponse> listener)  
      void close()  
      protected void createAlias​(String index, String createdIndexName)  
      protected org.elasticsearch.client.Client createHttpClient​(FessConfig fessConfig, String host)  
      boolean createIndex​(String index, String indexName)  
      boolean createIndex​(String index, String indexName, String numberOfShards, String autoExpandReplicas, boolean uploadConfig)  
      boolean delete​(String index, String id)  
      boolean delete​(String index, String id, Number seqNo, Number primaryTerm)  
      org.elasticsearch.action.ActionFuture<org.elasticsearch.action.delete.DeleteResponse> delete​(org.elasticsearch.action.delete.DeleteRequest request)  
      void delete​(org.elasticsearch.action.delete.DeleteRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.action.delete.DeleteResponse> listener)  
      long deleteByQuery​(String index, org.elasticsearch.index.query.QueryBuilder queryBuilder)  
      protected void deleteScrollContext​(String scrollId)  
      <Request extends org.elasticsearch.action.ActionRequest,​Response extends org.elasticsearch.action.ActionResponse>
      org.elasticsearch.action.ActionFuture<Response>      		 execute​(org.elasticsearch.action.ActionType<Response> action, Request request)  
      <Request extends org.elasticsearch.action.ActionRequest,​Response extends org.elasticsearch.action.ActionResponse>
      void      		 execute​(org.elasticsearch.action.ActionType<Response> action, Request request, org.elasticsearch.action.ActionListener<Response> listener)  
      boolean existsIndex​(String indexName)  
      org.elasticsearch.action.ActionFuture<org.elasticsearch.action.explain.ExplainResponse> explain​(org.elasticsearch.action.explain.ExplainRequest request)  
      void explain​(org.elasticsearch.action.explain.ExplainRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.action.explain.ExplainResponse> listener)  
      org.elasticsearch.action.ActionFuture<org.elasticsearch.action.fieldcaps.FieldCapabilitiesResponse> fieldCaps​(org.elasticsearch.action.fieldcaps.FieldCapabilitiesRequest request)  
      void fieldCaps​(org.elasticsearch.action.fieldcaps.FieldCapabilitiesRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.action.fieldcaps.FieldCapabilitiesResponse> listener)  
      org.elasticsearch.client.Client filterWithHeader​(Map<String,​String> headers)  
      void flush​(String... indices)  
      protected String generateNewIndexName​(String configIndex)  
      protected <T> T get​(String index, String type, String id, FessEsClient.SearchCondition<org.elasticsearch.action.get.GetRequestBuilder> condition, FessEsClient.SearchResult<T,​org.elasticsearch.action.get.GetRequestBuilder,​org.elasticsearch.action.get.GetResponse> searchResult)  
      org.elasticsearch.action.ActionFuture<org.elasticsearch.action.get.GetResponse> get​(org.elasticsearch.action.get.GetRequest request)  
      void get​(org.elasticsearch.action.get.GetRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.action.get.GetResponse> listener)  
      org.dbflute.optional.OptionalEntity<Map<String,​Object>> getDocument​(String index, FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition)  
      protected <T> org.dbflute.optional.OptionalEntity<T> getDocument​(String index, FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition, FessEsClient.EntityCreator<T,​org.elasticsearch.action.search.SearchResponse,​org.elasticsearch.search.SearchHit> creator)  
      List<Map<String,​Object>> getDocumentList​(String index, FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition)  
      protected <T> List<T> getDocumentList​(String index, FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition, FessEsClient.EntityCreator<T,​org.elasticsearch.action.search.SearchResponse,​org.elasticsearch.search.SearchHit> creator)  
      protected InetAddress getInetAddressByName​(String host)  
      String getStatus()  
      org.elasticsearch.action.ActionFuture<org.elasticsearch.action.index.IndexResponse> index​(org.elasticsearch.action.index.IndexRequest request)  
      void index​(org.elasticsearch.action.index.IndexRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.action.index.IndexResponse> listener)  
      protected void insertBulkData​(FessConfig fessConfig, String configIndex, String configType, String dataPath)  
      boolean isEmbedded()  
      org.elasticsearch.action.ActionFuture<org.elasticsearch.action.get.MultiGetResponse> multiGet​(org.elasticsearch.action.get.MultiGetRequest request)  
      void multiGet​(org.elasticsearch.action.get.MultiGetRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.action.get.MultiGetResponse> listener)  
      org.elasticsearch.action.ActionFuture<org.elasticsearch.action.search.MultiSearchResponse> multiSearch​(org.elasticsearch.action.search.MultiSearchRequest request)  
      void multiSearch​(org.elasticsearch.action.search.MultiSearchRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.MultiSearchResponse> listener)  
      org.elasticsearch.action.ActionFuture<org.elasticsearch.action.termvectors.MultiTermVectorsResponse> multiTermVectors​(org.elasticsearch.action.termvectors.MultiTermVectorsRequest request)  
      void multiTermVectors​(org.elasticsearch.action.termvectors.MultiTermVectorsRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.action.termvectors.MultiTermVectorsResponse> listener)  
      void open()  
      PingResponse ping()  
      org.elasticsearch.action.bulk.BulkRequestBuilder prepareBulk()  
      org.elasticsearch.action.bulk.BulkRequestBuilder prepareBulk​(String globalIndex, String globalType)  
      org.elasticsearch.action.search.ClearScrollRequestBuilder prepareClearScroll()  
      org.elasticsearch.action.delete.DeleteRequestBuilder prepareDelete()  
      org.elasticsearch.action.delete.DeleteRequestBuilder prepareDelete​(String index, String type, String id)  
      org.elasticsearch.action.explain.ExplainRequestBuilder prepareExplain​(String index, String type, String id)  
      org.elasticsearch.action.fieldcaps.FieldCapabilitiesRequestBuilder prepareFieldCaps​(String... indices)  
      org.elasticsearch.action.get.GetRequestBuilder prepareGet()  
      org.elasticsearch.action.get.GetRequestBuilder prepareGet​(String index, String type, String id)  
      org.elasticsearch.action.index.IndexRequestBuilder prepareIndex()  
      org.elasticsearch.action.index.IndexRequestBuilder prepareIndex​(String index, String type)  
      org.elasticsearch.action.index.IndexRequestBuilder prepareIndex​(String index, String type, String id)  
      org.elasticsearch.action.get.MultiGetRequestBuilder prepareMultiGet()  
      org.elasticsearch.action.search.MultiSearchRequestBuilder prepareMultiSearch()  
      org.elasticsearch.action.termvectors.MultiTermVectorsRequestBuilder prepareMultiTermVectors()  
      org.elasticsearch.action.search.SearchRequestBuilder prepareSearch​(String... indices)  
      org.elasticsearch.action.search.SearchScrollRequestBuilder prepareSearchScroll​(String scrollId)  
      org.elasticsearch.action.termvectors.TermVectorsRequestBuilder prepareTermVectors()  
      org.elasticsearch.action.termvectors.TermVectorsRequestBuilder prepareTermVectors​(String index, String type, String id)  
      org.elasticsearch.action.update.UpdateRequestBuilder prepareUpdate()  
      org.elasticsearch.action.update.UpdateRequestBuilder prepareUpdate​(String index, String type, String id)  
      void refresh​(String... indices)  
      boolean reindex​(String fromIndex, String toIndex, boolean waitForCompletion)  
      <T> long scrollSearch​(String index, FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition, FessEsClient.EntityCreator<T,​org.elasticsearch.action.search.SearchResponse,​org.elasticsearch.search.SearchHit> creator, Function<T,​Boolean> cursor)  
      <T> T search​(String index, FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition, FessEsClient.SearchResult<T,​org.elasticsearch.action.search.SearchRequestBuilder,​org.elasticsearch.action.search.SearchResponse> searchResult)  
      org.elasticsearch.action.ActionFuture<org.elasticsearch.action.search.SearchResponse> search​(org.elasticsearch.action.search.SearchRequest request)  
      void search​(org.elasticsearch.action.search.SearchRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.SearchResponse> listener)  
      org.elasticsearch.action.ActionFuture<org.elasticsearch.action.search.SearchResponse> searchScroll​(org.elasticsearch.action.search.SearchScrollRequest request)  
      void searchScroll​(org.elasticsearch.action.search.SearchScrollRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.SearchResponse> listener)  
      protected void sendConfigFiles​(String index)  
      void setClusterName​(String clusterName)  
      void setIndexConfigPath​(String indexConfigPath)  
      void setMaxConfigSyncStatusRetry​(int maxConfigSyncStatusRetry)  
      void setMaxEsStatusRetry​(int maxEsStatusRetry)  
      void setRunner​(org.codelibs.elasticsearch.runner.ElasticsearchClusterRunner runner)  
      void setScrollForDelete​(String scrollForDelete)  
      void setScrollForSearch​(String scrollForSearch)  
      void setScrollForUpdate​(String scrollForUpdate)  
      void setSettings​(Map<String,​String> settings)  
      void setSizeForDelete​(int sizeForDelete)  
      void setSizeForUpdate​(int sizeForUpdate)  
      org.elasticsearch.common.settings.Settings settings()  
      boolean store​(String index, Object obj)  
      org.elasticsearch.action.ActionFuture<org.elasticsearch.action.termvectors.TermVectorsResponse> termVectors​(org.elasticsearch.action.termvectors.TermVectorsRequest request)  
      void termVectors​(org.elasticsearch.action.termvectors.TermVectorsRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.action.termvectors.TermVectorsResponse> listener)  
      org.elasticsearch.threadpool.ThreadPool threadPool()  
      boolean update​(String index, String id, String field, Object value)  
      org.elasticsearch.action.ActionFuture<org.elasticsearch.action.update.UpdateResponse> update​(org.elasticsearch.action.update.UpdateRequest request)  
      void update​(org.elasticsearch.action.update.UpdateRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.action.update.UpdateResponse> listener)  
      boolean updateAlias​(String newIndex)  
      long updateByQuery​(String index, Function<org.elasticsearch.action.search.SearchRequestBuilder,​org.elasticsearch.action.search.SearchRequestBuilder> option, BiFunction<org.elasticsearch.action.update.UpdateRequestBuilder,​org.elasticsearch.search.SearchHit,​org.elasticsearch.action.update.UpdateRequestBuilder> builder)  
      protected void waitForConfigSyncStatus()  
      protected void waitForYellowStatus​(FessConfig fessConfig)  

      • Methods inherited from interface org.elasticsearch.client.Client

        getRemoteClusterClient

    • Field Detail

      • runner

        protected org.codelibs.elasticsearch.runner.ElasticsearchClusterRunner runner

      • httpAddress

        protected String httpAddress

      • client

        protected org.elasticsearch.client.Client client

      • indexConfigPath

        protected String indexConfigPath

      • indexConfigList

        protected List<String> indexConfigList

      • scrollForSearch

        protected String scrollForSearch

      • sizeForDelete

        protected int sizeForDelete

      • scrollForDelete

        protected String scrollForDelete

      • sizeForUpdate

        protected int sizeForUpdate

      • scrollForUpdate

        protected String scrollForUpdate

      • maxConfigSyncStatusRetry

        protected int maxConfigSyncStatusRetry

      • maxEsStatusRetry

        protected int maxEsStatusRetry

      • clusterName

        protected String clusterName

    • Constructor Detail

      • FessEsClient

        public FessEsClient()

    • Method Detail

      • addIndexConfig

        public void addIndexConfig​(String path)

      • addConfigFile

        public void addConfigFile​(String index,
                          String path)

      • setSettings

        public void setSettings​(Map<String,​String> settings)

      • getStatus

        public String getStatus()

      • setRunner

        public void setRunner​(org.codelibs.elasticsearch.runner.ElasticsearchClusterRunner runner)

      • isEmbedded

        public boolean isEmbedded()

      • open

        @PostConstruct
public void open()

      • createHttpClient

        protected org.elasticsearch.client.Client createHttpClient​(FessConfig fessConfig,
                                                           String host)

      • existsIndex

        public boolean existsIndex​(String indexName)

      • reindex

        public boolean reindex​(String fromIndex,
                       String toIndex,
                       boolean waitForCompletion)

      • createIndex

        public boolean createIndex​(String index,
                           String indexName)

      • createIndex

        public boolean createIndex​(String index,
                           String indexName,
                           String numberOfShards,
                           String autoExpandReplicas,
                           boolean uploadConfig)

      • addMapping

        public void addMapping​(String index,
                       String docType,
                       String indexName)

      • updateAlias

        public boolean updateAlias​(String newIndex)

      • createAlias

        protected void createAlias​(String index,
                           String createdIndexName)

      • sendConfigFiles

        protected void sendConfigFiles​(String index)

      • generateNewIndexName

        protected String generateNewIndexName​(String configIndex)

      • waitForYellowStatus

        protected void waitForYellowStatus​(FessConfig fessConfig)

      • waitForConfigSyncStatus

        protected void waitForConfigSyncStatus()

      • close

        @PreDestroy
public void close()
        Specified by:
        close in interface AutoCloseable
        Specified by:
        close in interface Closeable
        Specified by:
        close in interface org.elasticsearch.common.lease.Releasable

      • updateByQuery

        public long updateByQuery​(String index,
                          Function<org.elasticsearch.action.search.SearchRequestBuilder,​org.elasticsearch.action.search.SearchRequestBuilder> option,
                          BiFunction<org.elasticsearch.action.update.UpdateRequestBuilder,​org.elasticsearch.search.SearchHit,​org.elasticsearch.action.update.UpdateRequestBuilder> builder)

      • deleteByQuery

        public long deleteByQuery​(String index,
                          org.elasticsearch.index.query.QueryBuilder queryBuilder)

      • deleteScrollContext

        protected void deleteScrollContext​(String scrollId)

      • getDocument

        protected <T> org.dbflute.optional.OptionalEntity<T> getDocument​(String index,
                                                                 FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition,
                                                                 FessEsClient.EntityCreator<T,​org.elasticsearch.action.search.SearchResponse,​org.elasticsearch.search.SearchHit> creator)

      • refresh

        public void refresh​(String... indices)

      • flush

        public void flush​(String... indices)

      • store

        public boolean store​(String index,
                     Object obj)

      • delete

        public boolean delete​(String index,
                      String id)

      • setIndexConfigPath

        public void setIndexConfigPath​(String indexConfigPath)

      • setClusterName

        public void setClusterName​(String clusterName)

      • threadPool

        public org.elasticsearch.threadpool.ThreadPool threadPool()
        Specified by:
        threadPool in interface org.elasticsearch.client.ElasticsearchClient

      • admin

        public org.elasticsearch.client.AdminClient admin()
        Specified by:
        admin in interface org.elasticsearch.client.Client

      • index

        public org.elasticsearch.action.ActionFuture<org.elasticsearch.action.index.IndexResponse> index​(org.elasticsearch.action.index.IndexRequest request)
        Specified by:
        index in interface org.elasticsearch.client.Client

      • index

        public void index​(org.elasticsearch.action.index.IndexRequest request,
                  org.elasticsearch.action.ActionListener<org.elasticsearch.action.index.IndexResponse> listener)
        Specified by:
        index in interface org.elasticsearch.client.Client

      • prepareIndex

        public org.elasticsearch.action.index.IndexRequestBuilder prepareIndex()
        Specified by:
        prepareIndex in interface org.elasticsearch.client.Client

      • update

        public org.elasticsearch.action.ActionFuture<org.elasticsearch.action.update.UpdateResponse> update​(org.elasticsearch.action.update.UpdateRequest request)
        Specified by:
        update in interface org.elasticsearch.client.Client

      • update

        public void update​(org.elasticsearch.action.update.UpdateRequest request,
                   org.elasticsearch.action.ActionListener<org.elasticsearch.action.update.UpdateResponse> listener)
        Specified by:
        update in interface org.elasticsearch.client.Client

      • prepareUpdate

        public org.elasticsearch.action.update.UpdateRequestBuilder prepareUpdate()
        Specified by:
        prepareUpdate in interface org.elasticsearch.client.Client

      • prepareUpdate

        public org.elasticsearch.action.update.UpdateRequestBuilder prepareUpdate​(String index,
                                                                          String type,
                                                                          String id)
        Specified by:
        prepareUpdate in interface org.elasticsearch.client.Client

      • prepareIndex

        public org.elasticsearch.action.index.IndexRequestBuilder prepareIndex​(String index,
                                                                       String type)
        Specified by:
        prepareIndex in interface org.elasticsearch.client.Client

      • prepareIndex

        public org.elasticsearch.action.index.IndexRequestBuilder prepareIndex​(String index,
                                                                       String type,
                                                                       String id)
        Specified by:
        prepareIndex in interface org.elasticsearch.client.Client

      • delete

        public org.elasticsearch.action.ActionFuture<org.elasticsearch.action.delete.DeleteResponse> delete​(org.elasticsearch.action.delete.DeleteRequest request)
        Specified by:
        delete in interface org.elasticsearch.client.Client

      • delete

        public void delete​(org.elasticsearch.action.delete.DeleteRequest request,
                   org.elasticsearch.action.ActionListener<org.elasticsearch.action.delete.DeleteResponse> listener)
        Specified by:
        delete in interface org.elasticsearch.client.Client

      • prepareDelete

        public org.elasticsearch.action.delete.DeleteRequestBuilder prepareDelete()
        Specified by:
        prepareDelete in interface org.elasticsearch.client.Client

      • prepareDelete

        public org.elasticsearch.action.delete.DeleteRequestBuilder prepareDelete​(String index,
                                                                          String type,
                                                                          String id)
        Specified by:
        prepareDelete in interface org.elasticsearch.client.Client

      • bulk

        public org.elasticsearch.action.ActionFuture<org.elasticsearch.action.bulk.BulkResponse> bulk​(org.elasticsearch.action.bulk.BulkRequest request)
        Specified by:
        bulk in interface org.elasticsearch.client.Client

      • bulk

        public void bulk​(org.elasticsearch.action.bulk.BulkRequest request,
                 org.elasticsearch.action.ActionListener<org.elasticsearch.action.bulk.BulkResponse> listener)
        Specified by:
        bulk in interface org.elasticsearch.client.Client

      • prepareBulk

        public org.elasticsearch.action.bulk.BulkRequestBuilder prepareBulk()
        Specified by:
        prepareBulk in interface org.elasticsearch.client.Client

      • get

        public org.elasticsearch.action.ActionFuture<org.elasticsearch.action.get.GetResponse> get​(org.elasticsearch.action.get.GetRequest request)
        Specified by:
        get in interface org.elasticsearch.client.Client

      • get

        public void get​(org.elasticsearch.action.get.GetRequest request,
                org.elasticsearch.action.ActionListener<org.elasticsearch.action.get.GetResponse> listener)
        Specified by:
        get in interface org.elasticsearch.client.Client

      • prepareGet

        public org.elasticsearch.action.get.GetRequestBuilder prepareGet()
        Specified by:
        prepareGet in interface org.elasticsearch.client.Client

      • prepareGet

        public org.elasticsearch.action.get.GetRequestBuilder prepareGet​(String index,
                                                                 String type,
                                                                 String id)
        Specified by:
        prepareGet in interface org.elasticsearch.client.Client

      • multiGet

        public org.elasticsearch.action.ActionFuture<org.elasticsearch.action.get.MultiGetResponse> multiGet​(org.elasticsearch.action.get.MultiGetRequest request)
        Specified by:
        multiGet in interface org.elasticsearch.client.Client

      • multiGet

        public void multiGet​(org.elasticsearch.action.get.MultiGetRequest request,
                     org.elasticsearch.action.ActionListener<org.elasticsearch.action.get.MultiGetResponse> listener)
        Specified by:
        multiGet in interface org.elasticsearch.client.Client

      • prepareMultiGet

        public org.elasticsearch.action.get.MultiGetRequestBuilder prepareMultiGet()
        Specified by:
        prepareMultiGet in interface org.elasticsearch.client.Client

      • search

        public org.elasticsearch.action.ActionFuture<org.elasticsearch.action.search.SearchResponse> search​(org.elasticsearch.action.search.SearchRequest request)
        Specified by:
        search in interface org.elasticsearch.client.Client

      • search

        public void search​(org.elasticsearch.action.search.SearchRequest request,
                   org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.SearchResponse> listener)
        Specified by:
        search in interface org.elasticsearch.client.Client

      • prepareSearch

        public org.elasticsearch.action.search.SearchRequestBuilder prepareSearch​(String... indices)
        Specified by:
        prepareSearch in interface org.elasticsearch.client.Client

      • searchScroll

        public org.elasticsearch.action.ActionFuture<org.elasticsearch.action.search.SearchResponse> searchScroll​(org.elasticsearch.action.search.SearchScrollRequest request)
        Specified by:
        searchScroll in interface org.elasticsearch.client.Client

      • searchScroll

        public void searchScroll​(org.elasticsearch.action.search.SearchScrollRequest request,
                         org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.SearchResponse> listener)
        Specified by:
        searchScroll in interface org.elasticsearch.client.Client

      • prepareSearchScroll

        public org.elasticsearch.action.search.SearchScrollRequestBuilder prepareSearchScroll​(String scrollId)
        Specified by:
        prepareSearchScroll in interface org.elasticsearch.client.Client

      • multiSearch

        public org.elasticsearch.action.ActionFuture<org.elasticsearch.action.search.MultiSearchResponse> multiSearch​(org.elasticsearch.action.search.MultiSearchRequest request)
        Specified by:
        multiSearch in interface org.elasticsearch.client.Client

      • multiSearch

        public void multiSearch​(org.elasticsearch.action.search.MultiSearchRequest request,
                        org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.MultiSearchResponse> listener)
        Specified by:
        multiSearch in interface org.elasticsearch.client.Client

      • prepareMultiSearch

        public org.elasticsearch.action.search.MultiSearchRequestBuilder prepareMultiSearch()
        Specified by:
        prepareMultiSearch in interface org.elasticsearch.client.Client

      • prepareExplain

        public org.elasticsearch.action.explain.ExplainRequestBuilder prepareExplain​(String index,
                                                                             String type,
                                                                             String id)
        Specified by:
        prepareExplain in interface org.elasticsearch.client.Client

      • explain

        public org.elasticsearch.action.ActionFuture<org.elasticsearch.action.explain.ExplainResponse> explain​(org.elasticsearch.action.explain.ExplainRequest request)
        Specified by:
        explain in interface org.elasticsearch.client.Client

      • explain

        public void explain​(org.elasticsearch.action.explain.ExplainRequest request,
                    org.elasticsearch.action.ActionListener<org.elasticsearch.action.explain.ExplainResponse> listener)
        Specified by:
        explain in interface org.elasticsearch.client.Client

      • prepareClearScroll

        public org.elasticsearch.action.search.ClearScrollRequestBuilder prepareClearScroll()
        Specified by:
        prepareClearScroll in interface org.elasticsearch.client.Client

      • clearScroll

        public org.elasticsearch.action.ActionFuture<org.elasticsearch.action.search.ClearScrollResponse> clearScroll​(org.elasticsearch.action.search.ClearScrollRequest request)
        Specified by:
        clearScroll in interface org.elasticsearch.client.Client

      • clearScroll

        public void clearScroll​(org.elasticsearch.action.search.ClearScrollRequest request,
                        org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.ClearScrollResponse> listener)
        Specified by:
        clearScroll in interface org.elasticsearch.client.Client

      • settings

        public org.elasticsearch.common.settings.Settings settings()
        Specified by:
        settings in interface org.elasticsearch.client.Client

      • termVectors

        public org.elasticsearch.action.ActionFuture<org.elasticsearch.action.termvectors.TermVectorsResponse> termVectors​(org.elasticsearch.action.termvectors.TermVectorsRequest request)
        Specified by:
        termVectors in interface org.elasticsearch.client.Client

      • termVectors

        public void termVectors​(org.elasticsearch.action.termvectors.TermVectorsRequest request,
                        org.elasticsearch.action.ActionListener<org.elasticsearch.action.termvectors.TermVectorsResponse> listener)
        Specified by:
        termVectors in interface org.elasticsearch.client.Client

      • prepareTermVectors

        public org.elasticsearch.action.termvectors.TermVectorsRequestBuilder prepareTermVectors()
        Specified by:
        prepareTermVectors in interface org.elasticsearch.client.Client

      • prepareTermVectors

        public org.elasticsearch.action.termvectors.TermVectorsRequestBuilder prepareTermVectors​(String index,
                                                                                         String type,
                                                                                         String id)
        Specified by:
        prepareTermVectors in interface org.elasticsearch.client.Client

      • multiTermVectors

        public org.elasticsearch.action.ActionFuture<org.elasticsearch.action.termvectors.MultiTermVectorsResponse> multiTermVectors​(org.elasticsearch.action.termvectors.MultiTermVectorsRequest request)
        Specified by:
        multiTermVectors in interface org.elasticsearch.client.Client

      • multiTermVectors

        public void multiTermVectors​(org.elasticsearch.action.termvectors.MultiTermVectorsRequest request,
                             org.elasticsearch.action.ActionListener<org.elasticsearch.action.termvectors.MultiTermVectorsResponse> listener)
        Specified by:
        multiTermVectors in interface org.elasticsearch.client.Client

      • prepareMultiTermVectors

        public org.elasticsearch.action.termvectors.MultiTermVectorsRequestBuilder prepareMultiTermVectors()
        Specified by:
        prepareMultiTermVectors in interface org.elasticsearch.client.Client

      • setSizeForUpdate

        public void setSizeForUpdate​(int sizeForUpdate)

      • setScrollForUpdate

        public void setScrollForUpdate​(String scrollForUpdate)

      • setSizeForDelete

        public void setSizeForDelete​(int sizeForDelete)

      • setScrollForDelete

        public void setScrollForDelete​(String scrollForDelete)

      • setScrollForSearch

        public void setScrollForSearch​(String scrollForSearch)

      • setMaxConfigSyncStatusRetry

        public void setMaxConfigSyncStatusRetry​(int maxConfigSyncStatusRetry)

      • setMaxEsStatusRetry

        public void setMaxEsStatusRetry​(int maxEsStatusRetry)

      • filterWithHeader

        public org.elasticsearch.client.Client filterWithHeader​(Map<String,​String> headers)
        Specified by:
        filterWithHeader in interface org.elasticsearch.client.Client

      • execute

        public <Request extends org.elasticsearch.action.ActionRequest,​Response extends org.elasticsearch.action.ActionResponse> org.elasticsearch.action.ActionFuture<Response> execute​(org.elasticsearch.action.ActionType<Response> action,
                                                                                                                                                                                       Request request)
        Specified by:
        execute in interface org.elasticsearch.client.ElasticsearchClient

      • execute

        public <Request extends org.elasticsearch.action.ActionRequest,​Response extends org.elasticsearch.action.ActionResponse> void execute​(org.elasticsearch.action.ActionType<Response> action,
                                                                                                                                            Request request,
                                                                                                                                            org.elasticsearch.action.ActionListener<Response> listener)
        Specified by:
        execute in interface org.elasticsearch.client.ElasticsearchClient

      • prepareFieldCaps

        public org.elasticsearch.action.fieldcaps.FieldCapabilitiesRequestBuilder prepareFieldCaps​(String... indices)
        Specified by:
        prepareFieldCaps in interface org.elasticsearch.client.Client

      • fieldCaps

        public org.elasticsearch.action.ActionFuture<org.elasticsearch.action.fieldcaps.FieldCapabilitiesResponse> fieldCaps​(org.elasticsearch.action.fieldcaps.FieldCapabilitiesRequest request)
        Specified by:
        fieldCaps in interface org.elasticsearch.client.Client

      • fieldCaps

        public void fieldCaps​(org.elasticsearch.action.fieldcaps.FieldCapabilitiesRequest request,
                      org.elasticsearch.action.ActionListener<org.elasticsearch.action.fieldcaps.FieldCapabilitiesResponse> listener)
        Specified by:
        fieldCaps in interface org.elasticsearch.client.Client

      • prepareBulk

        public org.elasticsearch.action.bulk.BulkRequestBuilder prepareBulk​(String globalIndex,
                                                                    String globalType)
        Specified by:
        prepareBulk in interface org.elasticsearch.client.Client