public class ElasticsearchUtil
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected static java.lang.String |
index |
protected static java.lang.String |
type |
Constructor and Description |
---|
ElasticsearchUtil() |
Modifier and Type | Method and Description |
---|---|
static void |
clearElasticsearch(ElasticsearchConfig elasticsearchConfig)
Clears Elasticsearch
|
static void |
commit(ElasticsearchConfig elasticsearchConfig)
No need to deal with concurrency in Elasticsearch
|
static void |
createIndex(ElasticsearchConfig elasticsearchConfig)
Creates the Elasticsearch index with the analyzers and mappings
|
static java.util.Map<java.lang.String,java.lang.Object> |
getDocumentById(java.lang.String objectId,
ElasticsearchConfig elasticsearchConfig)
Gets document by id
|
static void |
indexDocument(java.io.InputStream is,
java.lang.String objectId,
java.util.Map<java.lang.String,java.lang.Object[]> metadata,
ElasticsearchConfig elasticsearchConfig)
Indexes document; these "indexes" are treated as "upserts" which means that
it will update properties if they exist or insert if they do not, this is to
prevent erasing properties on updates
|
static void |
indexDocument(java.io.InputStream is,
java.lang.String objectId,
java.util.Map<java.lang.String,java.lang.Object[]> metadata,
int commitWithin,
ElasticsearchConfig elasticsearchConfig)
Indexes document but flushes the changes immediately
|
static void |
removeDocumentById(java.lang.String objectId,
ElasticsearchConfig elasticsearchConfig)
Deletes document by id
|
protected static final java.lang.String index
protected static final java.lang.String type
public static void createIndex(ElasticsearchConfig elasticsearchConfig)
elasticsearchConfig
- public static void indexDocument(java.io.InputStream is, java.lang.String objectId, java.util.Map<java.lang.String,java.lang.Object[]> metadata, int commitWithin, ElasticsearchConfig elasticsearchConfig)
{InputStream}
- is{String}
- objectId{Map - Object[]> metadata
{int}
- commit within{ElasticsearchConfig}
- elasticsearchConfigpublic static void indexDocument(java.io.InputStream is, java.lang.String objectId, java.util.Map<java.lang.String,java.lang.Object[]> metadata, ElasticsearchConfig elasticsearchConfig)
{InputStream}
- is{String}
- objectId{Map - Object[]> metadata
{ElasticsearchConfig}
- elasticsearchConfigpublic static void removeDocumentById(java.lang.String objectId, ElasticsearchConfig elasticsearchConfig)
{String}
- objectId{ElasticsearchConfig}
- elasticsearchConfigpublic static java.util.Map<java.lang.String,java.lang.Object> getDocumentById(java.lang.String objectId, ElasticsearchConfig elasticsearchConfig)
{String}
- objectId{ElasticsearchConfig}
- elasticsearchConfigpublic static void clearElasticsearch(ElasticsearchConfig elasticsearchConfig)
{ElasticsearchConfig}
- elasticsearchConfigpublic static void commit(ElasticsearchConfig elasticsearchConfig)
elasticsearchConfig
-