org.hibernate.search.elasticsearch.client.impl

Class JestClient

java.lang.Object

org.hibernate.search.elasticsearch.client.impl.JestClient

All Implemented Interfaces:

Service, Startable, Stoppable

public class JestClient
extends Object
implements Service, Startable, Stoppable

Provides access to the JEST client.

Author:

Gunnar Morling

Constructor Summary

Constructors

Constructor and Description
JestClient()

Method Summary

Modifier and Type	Method and Description
Map<BackendRequest<?>,io.searchbox.core.BulkResult.BulkResultItem>	executeBulkRequest(List<BackendRequest<?>> backendRequests, boolean refresh) Creates a bulk action from the given list and executes it.
<T extends io.searchbox.client.JestResult> T	executeRequest(io.searchbox.action.Action<T> request)
<T extends io.searchbox.client.JestResult> T	executeRequest(io.searchbox.action.Action<T> request, BackendRequestResultAssessor<? super T> resultAssessor)
void	start(Properties properties, BuildContext context) Start phase notification.
void	stop() Stop phase notification

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JestClient

public JestClient()

Method Detail

start

public void start(Properties properties,
                  BuildContext context)

Description copied from interface: Startable

Start phase notification.

Specified by:

start in interface Startable

Parameters:

properties - the configuration properties

context - the current context instance

stop

public void stop()

Description copied from interface: Stoppable

Stop phase notification

Specified by:

stop in interface Stoppable

executeRequest

public <T extends io.searchbox.client.JestResult> T executeRequest(io.searchbox.action.Action<T> request)

executeRequest

public <T extends io.searchbox.client.JestResult> T executeRequest(io.searchbox.action.Action<T> request,
                                                                   BackendRequestResultAssessor<? super T> resultAssessor)

executeBulkRequest

public Map<BackendRequest<?>,io.searchbox.core.BulkResult.BulkResultItem> executeBulkRequest(List<BackendRequest<?>> backendRequests,
                                                                                             boolean refresh)

Creates a bulk action from the given list and executes it.