public interface DocumentOperations
Modifier and Type | Method and Description |
---|---|
List<String> |
bulkIndex(List<IndexQuery> queries,
BulkOptions bulkOptions,
IndexCoordinates index)
Bulk index all objects.
|
default List<String> |
bulkIndex(List<IndexQuery> queries,
IndexCoordinates index)
Bulk index all objects.
|
void |
bulkUpdate(List<UpdateQuery> queries,
BulkOptions bulkOptions,
IndexCoordinates index)
Bulk update all objects.
|
default void |
bulkUpdate(List<UpdateQuery> queries,
IndexCoordinates index)
Bulk update all objects.
|
void |
delete(DeleteQuery query,
IndexCoordinates index)
Delete all records matching the query.
|
void |
delete(Query query,
Class<?> clazz,
IndexCoordinates index)
Delete all records matching the query.
|
String |
delete(String id,
IndexCoordinates index)
Delete the one object with provided id.
|
<T> T |
get(GetQuery query,
Class<T> clazz,
IndexCoordinates index)
Retrieves an object from an index.
|
String |
index(IndexQuery query,
IndexCoordinates index)
Index an object.
|
<T> List<T> |
multiGet(Query query,
Class<T> clazz,
IndexCoordinates index)
Execute a multiGet against elasticsearch for the given ids.
|
<T> Iterable<T> |
save(Iterable<T> entities)
saves the given entities to the index retrieved from the entities' Document annotation
|
<T> Iterable<T> |
save(Iterable<T> entities,
IndexCoordinates index)
saves the given entities to the given index
|
<T> Iterable<T> |
save(T... entities)
saves the given entities to the index retrieved from the entities' Document annotation
|
<T> T |
save(T entity)
Saves an entity to the index specified in the entity's Document annotation
|
<T> T |
save(T entity,
IndexCoordinates index)
Saves an entity to the index specified in the entity's Document annotation
|
org.elasticsearch.action.update.UpdateResponse |
update(UpdateQuery updateQuery,
IndexCoordinates index)
Partial update of the document.
|
<T> T save(T entity)
T
- the entity typeentity
- the entity to save, must not be null<T> T save(T entity, IndexCoordinates index)
T
- the entity typeentity
- the entity to save, must not be nullindex
- the index to save the entity in, must not be null<T> Iterable<T> save(Iterable<T> entities)
T
- the entity typeentities
- must not be null<T> Iterable<T> save(Iterable<T> entities, IndexCoordinates index)
T
- the entity typeentities
- must not be nullindex
- the idnex to save the entities in, must not be null<T> Iterable<T> save(T... entities)
T
- the entity typeentities
- must not be nullString index(IndexQuery query, IndexCoordinates index)
query
- the query defining the objectindex
- the index from which the object is read.@Nullable <T> T get(GetQuery query, Class<T> clazz, IndexCoordinates index)
query
- the query defining the id of the object to getclazz
- the type of the object to be returnedindex
- the index from which the object is read.<T> List<T> multiGet(Query query, Class<T> clazz, IndexCoordinates index)
query
- the query defining the ids of the objects to getclazz
- the type of the object to be returnedindex
- the index(es) from which the objects are read.default List<String> bulkIndex(List<IndexQuery> queries, IndexCoordinates index)
queries
- the queries to execute in bulkList<String> bulkIndex(List<IndexQuery> queries, BulkOptions bulkOptions, IndexCoordinates index)
queries
- the queries to execute in bulkbulkOptions
- options to be added to the bulk requestdefault void bulkUpdate(List<UpdateQuery> queries, IndexCoordinates index)
queries
- the queries to execute in bulkvoid bulkUpdate(List<UpdateQuery> queries, BulkOptions bulkOptions, IndexCoordinates index)
queries
- the queries to execute in bulkbulkOptions
- options to be added to the bulk requestString delete(String id, IndexCoordinates index)
id
- the document ot deleteindex
- the index from which to deletevoid delete(Query query, Class<?> clazz, IndexCoordinates index)
query
- query defining the objectsclazz
- The entity class, must be annotated with
Document
index
- the index from which to deletevoid delete(DeleteQuery query, IndexCoordinates index)
query
- query defining the objectsindex
- the index where to delete the recordsorg.elasticsearch.action.update.UpdateResponse update(UpdateQuery updateQuery, IndexCoordinates index)
updateQuery
- query defining the updateindex
- the index where to update the recordsCopyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.