Package com.netgrif.application.engine.elastic.service

Class ElasticIndexService

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void applyMappingSettings​(org.springframework.data.elasticsearch.core.document.Document mapping)  
      void applySettings​(java.util.HashMap<java.lang.String,​java.lang.Object> settingMap, java.lang.Class<?> clazz)  
      void bulkIndex​(boolean indexAll, java.time.LocalDateTime after, java.lang.Integer caseBatchSize, java.lang.Integer taskBatchSize)
      Performs bulk indexing of cases and tasks into Elasticsearch.
      void clearScrollHits​(java.util.List<java.lang.String> scrollIds)  
      boolean closeIndex​(java.lang.Class<?> clazz, java.lang.String... placeholders)  
      boolean createIndex​(java.lang.Class<?> clazz, java.lang.String... placeholders)  
      boolean deleteIndex​(java.lang.Class<?> clazz, java.lang.String... placeholders)  
      <T> java.lang.String index​(java.lang.Class<T> clazz, T source, java.lang.String... placeholders)  
      boolean indexExists​(java.lang.String indexName)  
      boolean openIndex​(java.lang.Class<?> clazz, java.lang.String... placeholders)  
      protected java.util.Map<java.lang.String,​java.lang.Object> parseAnalysisSettings()  
      java.util.Map<java.lang.String,​java.lang.Object> prepareAnalysisSettings()  
      boolean putMapping​(java.lang.Class<?> clazz, java.lang.String... placeholders)  
      boolean putTemplate​(java.lang.String name, java.lang.String source)  
      org.springframework.data.elasticsearch.core.SearchScrollHits<?> scroll​(java.lang.String scrollId, java.lang.Class<?> clazz, java.lang.String... placeholders)  
      org.springframework.data.elasticsearch.core.SearchScrollHits<?> scrollFirst​(org.springframework.data.elasticsearch.core.query.Query query, java.lang.Class<?> clazz, java.lang.String... placeholders)  
      org.springframework.data.elasticsearch.core.SearchHits<?> search​(org.springframework.data.elasticsearch.core.query.Query query, java.lang.Class<?> clazz, java.lang.String... placeholders)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • ElasticIndexService

        public ElasticIndexService​(org.springframework.context.ApplicationContext context,
                           org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate elasticsearchTemplate,
                           org.elasticsearch.client.RestHighLevelClient elasticsearchClient,
                           org.springframework.data.elasticsearch.core.ElasticsearchOperations operations,
                           ElasticsearchProperties elasticsearchProperties,
                           ElasticCaseRepository elasticCaseRepository,
                           ElasticTaskRepository elasticTaskRepository,
                           PetriNetService petriNetService,
                           org.springframework.data.mongodb.core.MongoTemplate mongoTemplate,
                           ElasticCaseMappingService caseMappingService,
                           ElasticTaskMappingService taskMappingService)

    • Method Detail

      • index

        public <T> java.lang.String index​(java.lang.Class<T> clazz,
                                  T source,
                                  java.lang.String... placeholders)
        Specified by:
        index in interface IElasticIndexService

      • createIndex

        public boolean createIndex​(java.lang.Class<?> clazz,
                           java.lang.String... placeholders)
        Specified by:
        createIndex in interface IElasticIndexService

      • applySettings

        public void applySettings​(java.util.HashMap<java.lang.String,​java.lang.Object> settingMap,
                          java.lang.Class<?> clazz)
        Specified by:
        applySettings in interface IElasticIndexService

      • parseAnalysisSettings

        protected java.util.Map<java.lang.String,​java.lang.Object> parseAnalysisSettings()

      • deleteIndex

        public boolean deleteIndex​(java.lang.Class<?> clazz,
                           java.lang.String... placeholders)
        Specified by:
        deleteIndex in interface IElasticIndexService

      • openIndex

        public boolean openIndex​(java.lang.Class<?> clazz,
                         java.lang.String... placeholders)
        Specified by:
        openIndex in interface IElasticIndexService

      • closeIndex

        public boolean closeIndex​(java.lang.Class<?> clazz,
                          java.lang.String... placeholders)
        Specified by:
        closeIndex in interface IElasticIndexService

      • search

        public org.springframework.data.elasticsearch.core.SearchHits<?> search​(org.springframework.data.elasticsearch.core.query.Query query,
                                                                        java.lang.Class<?> clazz,
                                                                        java.lang.String... placeholders)
        Specified by:
        search in interface IElasticIndexService

      • putMapping

        public boolean putMapping​(java.lang.Class<?> clazz,
                          java.lang.String... placeholders)
        Specified by:
        putMapping in interface IElasticIndexService

      • applyMappingSettings

        public void applyMappingSettings​(org.springframework.data.elasticsearch.core.document.Document mapping)
        Specified by:
        applyMappingSettings in interface IElasticIndexService

      • putTemplate

        public boolean putTemplate​(java.lang.String name,
                           java.lang.String source)
        Specified by:
        putTemplate in interface IElasticIndexService

      • scrollFirst

        public org.springframework.data.elasticsearch.core.SearchScrollHits<?> scrollFirst​(org.springframework.data.elasticsearch.core.query.Query query,
                                                                                   java.lang.Class<?> clazz,
                                                                                   java.lang.String... placeholders)
        Specified by:
        scrollFirst in interface IElasticIndexService

      • scroll

        public org.springframework.data.elasticsearch.core.SearchScrollHits<?> scroll​(java.lang.String scrollId,
                                                                              java.lang.Class<?> clazz,
                                                                              java.lang.String... placeholders)
        Specified by:
        scroll in interface IElasticIndexService

      • bulkIndex

        public void bulkIndex​(boolean indexAll,
                      java.time.LocalDateTime after,
                      java.lang.Integer caseBatchSize,
                      java.lang.Integer taskBatchSize)
        Performs bulk indexing of cases and tasks into Elasticsearch.
        Specified by:
        bulkIndex in interface IElasticIndexService
        Parameters:
        indexAll - if true, indexes all cases and tasks, regardless of modification time
        after - the time after which cases and tasks should be considered for reindexing
        caseBatchSize - number of cases to process per batch. If null, defaults from Elasticsearch properties
        taskBatchSize - number of tasks to process per batch. If null, defaults from Elasticsearch properties