static class ElasticFacadeImpl.ElasticClientImpl extends java.lang.Object implements ElasticFacade.ElasticClient
Constructor and description |
---|
ElasticClientImpl
(MNode clusterNode, ExecutionContextFactoryImpl ecfi) |
Type Params | Return Type | Name and description |
---|---|---|
|
boolean |
aliasExists(java.lang.String origAlias) |
|
void |
bulk(java.lang.String index, java.util.List<java.util.Map> actionSourceList) |
|
void |
bulkIndex(java.lang.String index, java.lang.String idField, java.util.List<java.util.Map> documentList) |
|
void |
bulkIndex(java.lang.String index, java.lang.String docType, java.lang.String idField, java.util.List<java.util.Map> documentList) |
|
void |
bulkIndexDataDocument(java.util.List<java.util.Map> documentList) |
|
RestResponse |
bulkResponse(java.lang.String index, java.util.List<java.util.Map> actionSourceList) |
|
RestResponse |
call(Method method, java.lang.String index, java.lang.String path, java.util.Map<java.lang.String, java.lang.String> parameters, java.lang.Object bodyJsonObject) |
|
Future<RestClient.RestResponse> |
callFuture(Method method, java.lang.String index, java.lang.String path, java.util.Map<java.lang.String, java.lang.String> parameters, java.lang.Object bodyJsonObject) |
|
void |
checkCreateDataDocumentIndex(java.lang.String dataDocumentId) |
|
void |
checkCreateDataDocumentIndexes(java.lang.String indexName) |
|
void |
createIndex(java.lang.String index, java.util.Map docMapping, java.lang.String origAlias) |
|
void |
createIndex(java.lang.String index, java.lang.String docType, java.util.Map docMapping, java.lang.String origAlias) |
|
void |
createIndex(java.lang.String index, java.lang.String docType, java.util.Map docMapping, java.lang.String origAlias, java.util.Map settings) |
|
void |
delete(java.lang.String index, java.lang.String _id) |
|
java.lang.Integer |
deleteByQuery(java.lang.String index, java.util.Map queryMap) |
|
void |
deleteIndex(java.lang.String index) |
|
void |
destroy() |
|
java.util.Map |
get(java.lang.String index, java.lang.String _id) |
|
java.util.List<java.util.Map> |
get(java.lang.String index, java.util.List<java.lang.String> _idList) |
|
java.lang.String |
getClusterLocation() |
|
java.lang.String |
getClusterName() |
|
java.util.Map |
getServerInfo() |
|
java.util.Map |
getSource(java.lang.String index, java.lang.String _id) |
|
void |
index(java.lang.String index, java.lang.String _id, java.util.Map document) |
|
boolean |
indexExists(java.lang.String index) |
|
boolean |
isEsVersionUnder7() |
|
java.lang.Object |
jsonToObject(java.lang.String jsonString) |
|
RestClient |
makeRestClient(Method method, java.lang.String index, java.lang.String path, java.util.Map<java.lang.String, java.lang.String> parameters) |
|
java.lang.String |
objectToJson(java.lang.Object jsonObject) |
|
java.lang.String |
prefixIndexName(java.lang.String index) |
|
void |
putDataDocumentMappings(java.lang.String indexName) |
|
void |
putMapping(java.lang.String index, java.util.Map docMapping) |
|
void |
putMapping(java.lang.String index, java.lang.String docType, java.util.Map docMapping) |
|
java.util.Map |
search(java.lang.String index, java.util.Map searchMap) |
|
java.util.List<java.util.Map> |
searchHits(java.lang.String origIndex, java.util.Map searchMap) |
|
protected void |
storeIndexAndMapping(java.lang.String indexName, EntityValue dd) |
|
java.lang.String |
unprefixIndexName(java.lang.String index) |
|
void |
update(java.lang.String index, java.lang.String _id, java.util.Map documentFragment) |
|
java.util.Map |
validateQuery(java.lang.String index, java.util.Map queryMap, boolean explain) |
|
void |
verifyDataDocumentIndexes(java.util.List<java.util.Map> documentList) |
Methods inherited from class | Name |
---|---|
class java.lang.Object |
java.lang.Object#wait(long), java.lang.Object#wait(long, int), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll() |