From 374acbdd6320e9d158001b5b600ab12f93164c6c Mon Sep 17 00:00:00 2001 From: Mohsin Husen Date: Tue, 15 Mar 2016 11:34:41 +0000 Subject: [PATCH] DATAES-124 - ElasticSearchTemplate should expose client --- .../data/elasticsearch/core/ElasticsearchOperations.java | 6 ++++++ .../data/elasticsearch/core/ElasticsearchTemplate.java | 5 +++++ 2 files changed, 11 insertions(+) diff --git a/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchOperations.java b/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchOperations.java index 86e8c0671..26a1dda34 100755 --- a/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchOperations.java +++ b/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchOperations.java @@ -16,6 +16,7 @@ package org.springframework.data.elasticsearch.core; import org.elasticsearch.action.update.UpdateResponse; +import org.elasticsearch.client.Client; import org.elasticsearch.cluster.metadata.AliasMetaData; import org.springframework.data.domain.Page; import org.springframework.data.elasticsearch.core.convert.ElasticsearchConverter; @@ -41,6 +42,11 @@ public interface ElasticsearchOperations { */ ElasticsearchConverter getElasticsearchConverter(); + /** + * @return elasticsearch client + */ + Client getClient(); + /** * Create an index for a class * diff --git a/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchTemplate.java b/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchTemplate.java index e342f5912..9bb081e16 100755 --- a/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchTemplate.java +++ b/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchTemplate.java @@ -139,6 +139,11 @@ public class ElasticsearchTemplate implements ElasticsearchOperations, Applicati this.resultsMapper = resultsMapper; } + @Override + public Client getClient() { + return client; + } + public void setSearchTimeout(String searchTimeout) { this.searchTimeout = searchTimeout; }