Loading src/main/java/es/redmic/elasticsearchlib/common/utils/ElasticPersistenceUtils.java +6 −7 Original line number Diff line number Diff line Loading @@ -47,10 +47,9 @@ import es.redmic.elasticsearchlib.config.EsClientProvider; import es.redmic.exception.common.ExceptionType; import es.redmic.exception.elasticsearch.ESUpdateException; import es.redmic.models.es.common.dto.EventApplicationResult; import es.redmic.models.es.common.model.BaseES; @Component public class ElasticPersistenceUtils<TModel extends BaseES<?>> { public class ElasticPersistenceUtils { protected static Logger logger = LogManager.getLogger(); Loading @@ -62,11 +61,11 @@ public class ElasticPersistenceUtils<TModel extends BaseES<?>> { protected static String SCRIPT_ENGINE = "groovy"; public EventApplicationResult save(String index, String type, TModel model, String id) { public <TModel> EventApplicationResult save(String index, String type, TModel model, String id) { return save(index, type, model, id, null); } public EventApplicationResult save(String index, String type, TModel model, String id, String parentId) { public <TModel> EventApplicationResult save(String index, String type, TModel model, String id, String parentId) { // @formatter:off Loading @@ -91,11 +90,11 @@ public class ElasticPersistenceUtils<TModel extends BaseES<?>> { } } public EventApplicationResult update(String index, String type, TModel model, String id) { public <TModel> EventApplicationResult update(String index, String type, TModel model, String id) { return update(index, type, model, id, null); } public EventApplicationResult update(String index, String type, TModel model, String id, String parentId) { public <TModel> EventApplicationResult update(String index, String type, TModel model, String id, String parentId) { // @formatter:off Loading Loading @@ -175,7 +174,7 @@ public class ElasticPersistenceUtils<TModel extends BaseES<?>> { } @SuppressWarnings("unchecked") protected Map<String, Object> convertTModelToSource(TModel modelToIndex) { protected <TModel> Map<String, Object> convertTModelToSource(TModel modelToIndex) { return objectMapper.convertValue(modelToIndex, Map.class); } Loading src/main/java/es/redmic/elasticsearchlib/data/repository/RWDataESRepository.java +1 −1 Original line number Diff line number Diff line Loading @@ -33,7 +33,7 @@ public abstract class RWDataESRepository<TModel extends BaseES<?>, TQueryDTO ext extends RDataESRepository<TModel, TQueryDTO> implements IRWBaseESRepository<TModel> { @Autowired ElasticPersistenceUtils<TModel> elasticPersistenceUtils; ElasticPersistenceUtils elasticPersistenceUtils; public RWDataESRepository() { super(); Loading src/main/java/es/redmic/elasticsearchlib/geodata/repository/RWGeoDataESRepository.java +1 −1 Original line number Diff line number Diff line Loading @@ -33,7 +33,7 @@ public abstract class RWGeoDataESRepository<TModel extends Feature<?, ?>, TQuery extends RGeoDataESRepository<TModel, TQueryDTO> implements IRWBaseESRepository<TModel> { @Autowired ElasticPersistenceUtils<TModel> elasticPersistenceUtils; ElasticPersistenceUtils elasticPersistenceUtils; public RWGeoDataESRepository(String[] index, String type, Boolean rollOverIndex) { super(index, type, rollOverIndex); Loading Loading
src/main/java/es/redmic/elasticsearchlib/common/utils/ElasticPersistenceUtils.java +6 −7 Original line number Diff line number Diff line Loading @@ -47,10 +47,9 @@ import es.redmic.elasticsearchlib.config.EsClientProvider; import es.redmic.exception.common.ExceptionType; import es.redmic.exception.elasticsearch.ESUpdateException; import es.redmic.models.es.common.dto.EventApplicationResult; import es.redmic.models.es.common.model.BaseES; @Component public class ElasticPersistenceUtils<TModel extends BaseES<?>> { public class ElasticPersistenceUtils { protected static Logger logger = LogManager.getLogger(); Loading @@ -62,11 +61,11 @@ public class ElasticPersistenceUtils<TModel extends BaseES<?>> { protected static String SCRIPT_ENGINE = "groovy"; public EventApplicationResult save(String index, String type, TModel model, String id) { public <TModel> EventApplicationResult save(String index, String type, TModel model, String id) { return save(index, type, model, id, null); } public EventApplicationResult save(String index, String type, TModel model, String id, String parentId) { public <TModel> EventApplicationResult save(String index, String type, TModel model, String id, String parentId) { // @formatter:off Loading @@ -91,11 +90,11 @@ public class ElasticPersistenceUtils<TModel extends BaseES<?>> { } } public EventApplicationResult update(String index, String type, TModel model, String id) { public <TModel> EventApplicationResult update(String index, String type, TModel model, String id) { return update(index, type, model, id, null); } public EventApplicationResult update(String index, String type, TModel model, String id, String parentId) { public <TModel> EventApplicationResult update(String index, String type, TModel model, String id, String parentId) { // @formatter:off Loading Loading @@ -175,7 +174,7 @@ public class ElasticPersistenceUtils<TModel extends BaseES<?>> { } @SuppressWarnings("unchecked") protected Map<String, Object> convertTModelToSource(TModel modelToIndex) { protected <TModel> Map<String, Object> convertTModelToSource(TModel modelToIndex) { return objectMapper.convertValue(modelToIndex, Map.class); } Loading
src/main/java/es/redmic/elasticsearchlib/data/repository/RWDataESRepository.java +1 −1 Original line number Diff line number Diff line Loading @@ -33,7 +33,7 @@ public abstract class RWDataESRepository<TModel extends BaseES<?>, TQueryDTO ext extends RDataESRepository<TModel, TQueryDTO> implements IRWBaseESRepository<TModel> { @Autowired ElasticPersistenceUtils<TModel> elasticPersistenceUtils; ElasticPersistenceUtils elasticPersistenceUtils; public RWDataESRepository() { super(); Loading
src/main/java/es/redmic/elasticsearchlib/geodata/repository/RWGeoDataESRepository.java +1 −1 Original line number Diff line number Diff line Loading @@ -33,7 +33,7 @@ public abstract class RWGeoDataESRepository<TModel extends Feature<?, ?>, TQuery extends RGeoDataESRepository<TModel, TQueryDTO> implements IRWBaseESRepository<TModel> { @Autowired ElasticPersistenceUtils<TModel> elasticPersistenceUtils; ElasticPersistenceUtils elasticPersistenceUtils; public RWGeoDataESRepository(String[] index, String type, Boolean rollOverIndex) { super(index, type, rollOverIndex); Loading