Package org.codelibs.fess.es.client

Class FessEsClient

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, org.elasticsearch.client.Client, org.elasticsearch.client.ElasticsearchClient, org.elasticsearch.common.lease.Releasable
    public class FessEsClient
extends java.lang.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​(java.lang.String index, java.util.List<java.util.Map<java.lang.String,​java.lang.Object>> docList, java.util.function.BiConsumer<java.util.Map<java.lang.String,​java.lang.Object>,​org.elasticsearch.action.index.IndexRequestBuilder> options)  
      void addConfigFile​(java.lang.String index, java.lang.String path)  
      void addIndexConfig​(java.lang.String path)  
      void addMapping​(java.lang.String index, java.lang.String docType, java.lang.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​(java.lang.String index, java.lang.String createdIndexName)  
      protected org.elasticsearch.client.Client createHttpClient​(FessConfig fessConfig, java.lang.String host)  
      boolean createIndex​(java.lang.String index, java.lang.String indexName)  
      boolean createIndex​(java.lang.String index, java.lang.String indexName, java.lang.String numberOfShards, java.lang.String autoExpandReplicas, boolean uploadConfig)  
      boolean delete​(java.lang.String index, java.lang.String id)  
      boolean delete​(java.lang.String index, java.lang.String id, java.lang.Number seqNo, java.lang.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​(java.lang.String index, org.elasticsearch.index.query.QueryBuilder queryBuilder)  
      protected void deleteScrollContext​(java.lang.String scrollId)  
      <Request extends org.elasticsearch.action.ActionRequest,​Response extends org.elasticsearch.action.ActionResponse>
      org.elasticsearch.action.ActionFuture<Response>      		 execute​(org.elasticsearch.action.Action<Response> action, Request request)  
      <Request extends org.elasticsearch.action.ActionRequest,​Response extends org.elasticsearch.action.ActionResponse>
      void      		 execute​(org.elasticsearch.action.Action<Response> action, Request request, org.elasticsearch.action.ActionListener<Response> listener)  
      boolean existsIndex​(java.lang.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​(java.util.Map<java.lang.String,​java.lang.String> headers)  
      void flush​(java.lang.String... indices)  
      protected java.lang.String generateNewIndexName​(java.lang.String configIndex)  
      protected <T> T get​(java.lang.String index, java.lang.String type, java.lang.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<java.util.Map<java.lang.String,​java.lang.Object>> getDocument​(java.lang.String index, FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition)  
      protected <T> org.dbflute.optional.OptionalEntity<T> getDocument​(java.lang.String index, FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition, FessEsClient.EntityCreator<T,​org.elasticsearch.action.search.SearchResponse,​org.elasticsearch.search.SearchHit> creator)  
      java.util.List<java.util.Map<java.lang.String,​java.lang.Object>> getDocumentList​(java.lang.String index, FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition)  
      protected <T> java.util.List<T> getDocumentList​(java.lang.String index, FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition, FessEsClient.EntityCreator<T,​org.elasticsearch.action.search.SearchResponse,​org.elasticsearch.search.SearchHit> creator)  
      protected java.net.InetAddress getInetAddressByName​(java.lang.String host)  
      java.lang.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, java.lang.String configIndex, java.lang.String configType, java.lang.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​(java.lang.String globalIndex, java.lang.String globalType)  
      org.elasticsearch.action.search.ClearScrollRequestBuilder prepareClearScroll()  
      org.elasticsearch.action.delete.DeleteRequestBuilder prepareDelete()  
      org.elasticsearch.action.delete.DeleteRequestBuilder prepareDelete​(java.lang.String index, java.lang.String type, java.lang.String id)  
      org.elasticsearch.action.explain.ExplainRequestBuilder prepareExplain​(java.lang.String index, java.lang.String type, java.lang.String id)  
      org.elasticsearch.action.fieldcaps.FieldCapabilitiesRequestBuilder prepareFieldCaps​(java.lang.String... indices)  
      org.elasticsearch.action.get.GetRequestBuilder prepareGet()  
      org.elasticsearch.action.get.GetRequestBuilder prepareGet​(java.lang.String index, java.lang.String type, java.lang.String id)  
      org.elasticsearch.action.index.IndexRequestBuilder prepareIndex()  
      org.elasticsearch.action.index.IndexRequestBuilder prepareIndex​(java.lang.String index, java.lang.String type)  
      org.elasticsearch.action.index.IndexRequestBuilder prepareIndex​(java.lang.String index, java.lang.String type, java.lang.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​(java.lang.String... indices)  
      org.elasticsearch.action.search.SearchScrollRequestBuilder prepareSearchScroll​(java.lang.String scrollId)  
      org.elasticsearch.action.termvectors.TermVectorsRequestBuilder prepareTermVectors()  
      org.elasticsearch.action.termvectors.TermVectorsRequestBuilder prepareTermVectors​(java.lang.String index, java.lang.String type, java.lang.String id)  
      org.elasticsearch.action.update.UpdateRequestBuilder prepareUpdate()  
      org.elasticsearch.action.update.UpdateRequestBuilder prepareUpdate​(java.lang.String index, java.lang.String type, java.lang.String id)  
      void refresh​(java.lang.String... indices)  
      boolean reindex​(java.lang.String fromIndex, java.lang.String toIndex, boolean waitForCompletion)  
      <T> long scrollSearch​(java.lang.String index, FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition, FessEsClient.EntityCreator<T,​org.elasticsearch.action.search.SearchResponse,​org.elasticsearch.search.SearchHit> creator, java.util.function.Function<T,​java.lang.Boolean> cursor)  
      <T> T search​(java.lang.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​(java.lang.String index)  
      void setClusterName​(java.lang.String clusterName)  
      void setIndexConfigPath​(java.lang.String indexConfigPath)  
      void setMaxConfigSyncStatusRetry​(int maxConfigSyncStatusRetry)  
      void setMaxEsStatusRetry​(int maxEsStatusRetry)  
      void setRunner​(org.codelibs.elasticsearch.runner.ElasticsearchClusterRunner runner)  
      void setScrollForDelete​(java.lang.String scrollForDelete)  
      void setScrollForSearch​(java.lang.String scrollForSearch)  
      void setScrollForUpdate​(java.lang.String scrollForUpdate)  
      void setSettings​(java.util.Map<java.lang.String,​java.lang.String> settings)  
      void setSizeForDelete​(int sizeForDelete)  
      void setSizeForUpdate​(int sizeForUpdate)  
      org.elasticsearch.common.settings.Settings settings()  
      boolean store​(java.lang.String index, java.lang.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​(java.lang.String index, java.lang.String id, java.lang.String field, java.lang.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​(java.lang.String newIndex)  
      long updateByQuery​(java.lang.String index, java.util.function.Function<org.elasticsearch.action.search.SearchRequestBuilder,​org.elasticsearch.action.search.SearchRequestBuilder> option, java.util.function.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 class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

        getRemoteClusterClient

    • Field Detail

      • runner

        protected org.codelibs.elasticsearch.runner.ElasticsearchClusterRunner runner

      • httpAddress

        protected java.lang.String httpAddress

      • client

        protected org.elasticsearch.client.Client client

      • settings

        protected java.util.Map<java.lang.String,​java.lang.String> settings

      • indexConfigPath

        protected java.lang.String indexConfigPath

      • indexConfigList

        protected java.util.List<java.lang.String> indexConfigList

      • configListMap

        protected java.util.Map<java.lang.String,​java.util.List<java.lang.String>> configListMap

      • scrollForSearch

        protected java.lang.String scrollForSearch

      • sizeForDelete

        protected int sizeForDelete

      • scrollForDelete

        protected java.lang.String scrollForDelete

      • sizeForUpdate

        protected int sizeForUpdate

      • scrollForUpdate

        protected java.lang.String scrollForUpdate

      • maxConfigSyncStatusRetry

        protected int maxConfigSyncStatusRetry

      • maxEsStatusRetry

        protected int maxEsStatusRetry

      • clusterName

        protected java.lang.String clusterName

    • Constructor Detail

      • FessEsClient

        public FessEsClient()

    • Method Detail

      • addIndexConfig

        public void addIndexConfig​(java.lang.String path)

      • addConfigFile

        public void addConfigFile​(java.lang.String index,
                          java.lang.String path)

      • setSettings

        public void setSettings​(java.util.Map<java.lang.String,​java.lang.String> settings)

      • getStatus

        public java.lang.String getStatus()

      • setRunner

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

      • isEmbedded

        public boolean isEmbedded()

      • getInetAddressByName

        protected java.net.InetAddress getInetAddressByName​(java.lang.String host)

      • open

        @PostConstruct
public void open()

      • createHttpClient

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

      • existsIndex

        public boolean existsIndex​(java.lang.String indexName)

      • reindex

        public boolean reindex​(java.lang.String fromIndex,
                       java.lang.String toIndex,
                       boolean waitForCompletion)

      • createIndex

        public boolean createIndex​(java.lang.String index,
                           java.lang.String indexName)

      • createIndex

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

      • addMapping

        public void addMapping​(java.lang.String index,
                       java.lang.String docType,
                       java.lang.String indexName)

      • updateAlias

        public boolean updateAlias​(java.lang.String newIndex)

      • createAlias

        protected void createAlias​(java.lang.String index,
                           java.lang.String createdIndexName)

      • sendConfigFiles

        protected void sendConfigFiles​(java.lang.String index)

      • generateNewIndexName

        protected java.lang.String generateNewIndexName​(java.lang.String configIndex)

      • insertBulkData

        protected void insertBulkData​(FessConfig fessConfig,
                              java.lang.String configIndex,
                              java.lang.String configType,
                              java.lang.String dataPath)

      • waitForYellowStatus

        protected void waitForYellowStatus​(FessConfig fessConfig)

      • waitForConfigSyncStatus

        protected void waitForConfigSyncStatus()

      • close

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

      • updateByQuery

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

      • deleteByQuery

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

      • deleteScrollContext

        protected void deleteScrollContext​(java.lang.String scrollId)

      • get

        protected <T> T get​(java.lang.String index,
                    java.lang.String type,
                    java.lang.String id,
                    FessEsClient.SearchCondition<org.elasticsearch.action.get.GetRequestBuilder> condition,
                    FessEsClient.SearchResult<T,​org.elasticsearch.action.get.GetRequestBuilder,​org.elasticsearch.action.get.GetResponse> searchResult)

      • search

        public <T> T search​(java.lang.String index,
                    FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition,
                    FessEsClient.SearchResult<T,​org.elasticsearch.action.search.SearchRequestBuilder,​org.elasticsearch.action.search.SearchResponse> searchResult)

      • scrollSearch

        public <T> long scrollSearch​(java.lang.String index,
                             FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition,
                             FessEsClient.EntityCreator<T,​org.elasticsearch.action.search.SearchResponse,​org.elasticsearch.search.SearchHit> creator,
                             java.util.function.Function<T,​java.lang.Boolean> cursor)

      • getDocument

        public org.dbflute.optional.OptionalEntity<java.util.Map<java.lang.String,​java.lang.Object>> getDocument​(java.lang.String index,
                                                                                                               FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition)

      • getDocument

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

      • getDocumentList

        public java.util.List<java.util.Map<java.lang.String,​java.lang.Object>> getDocumentList​(java.lang.String index,
                                                                                              FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition)

      • getDocumentList

        protected <T> java.util.List<T> getDocumentList​(java.lang.String index,
                                                FessEsClient.SearchCondition<org.elasticsearch.action.search.SearchRequestBuilder> condition,
                                                FessEsClient.EntityCreator<T,​org.elasticsearch.action.search.SearchResponse,​org.elasticsearch.search.SearchHit> creator)

      • update

        public boolean update​(java.lang.String index,
                      java.lang.String id,
                      java.lang.String field,
                      java.lang.Object value)

      • refresh

        public void refresh​(java.lang.String... indices)

      • flush

        public void flush​(java.lang.String... indices)

      • addAll

        public void addAll​(java.lang.String index,
                   java.util.List<java.util.Map<java.lang.String,​java.lang.Object>> docList,
                   java.util.function.BiConsumer<java.util.Map<java.lang.String,​java.lang.Object>,​org.elasticsearch.action.index.IndexRequestBuilder> options)

      • store

        public boolean store​(java.lang.String index,
                     java.lang.Object obj)

      • delete

        public boolean delete​(java.lang.String index,
                      java.lang.String id)

      • delete

        public boolean delete​(java.lang.String index,
                      java.lang.String id,
                      java.lang.Number seqNo,
                      java.lang.Number primaryTerm)

      • setIndexConfigPath

        public void setIndexConfigPath​(java.lang.String indexConfigPath)

      • setClusterName

        public void setClusterName​(java.lang.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​(java.lang.String index,
                                                                          java.lang.String type,
                                                                          java.lang.String id)
        Specified by:
        prepareUpdate in interface org.elasticsearch.client.Client

      • prepareIndex

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

      • prepareIndex

        public org.elasticsearch.action.index.IndexRequestBuilder prepareIndex​(java.lang.String index,
                                                                       java.lang.String type,
                                                                       java.lang.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​(java.lang.String index,
                                                                          java.lang.String type,
                                                                          java.lang.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​(java.lang.String index,
                                                                 java.lang.String type,
                                                                 java.lang.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​(java.lang.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​(java.lang.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​(java.lang.String index,
                                                                             java.lang.String type,
                                                                             java.lang.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​(java.lang.String index,
                                                                                         java.lang.String type,
                                                                                         java.lang.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​(java.lang.String scrollForUpdate)

      • setSizeForDelete

        public void setSizeForDelete​(int sizeForDelete)

      • setScrollForDelete

        public void setScrollForDelete​(java.lang.String scrollForDelete)

      • setScrollForSearch

        public void setScrollForSearch​(java.lang.String scrollForSearch)

      • setMaxConfigSyncStatusRetry

        public void setMaxConfigSyncStatusRetry​(int maxConfigSyncStatusRetry)

      • setMaxEsStatusRetry

        public void setMaxEsStatusRetry​(int maxEsStatusRetry)

      • filterWithHeader

        public org.elasticsearch.client.Client filterWithHeader​(java.util.Map<java.lang.String,​java.lang.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.Action<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.Action<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​(java.lang.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​(java.lang.String globalIndex,
                                                                    java.lang.String globalType)
        Specified by:
        prepareBulk in interface org.elasticsearch.client.Client