net.bluemind.lib.elasticsearch

Class Pit

java.lang.Object

net.bluemind.lib.elasticsearch.Pit

All Implemented Interfaces:

java.lang.AutoCloseable

public class Pit
extends java.lang.Object
implements java.lang.AutoCloseable

Field Summary

Fields

Modifier and Type	Field and Description
java.lang.String	id

Method Summary

Modifier and Type	Method and Description
void	adaptSearch(org.elasticsearch.action.search.SearchRequestBuilder searchBuilder)
static Pit	allocate(org.elasticsearch.client.Client client, java.lang.String index, int keepAliveInSeconds)
static Pit	allocateUsingTimebudget(org.elasticsearch.client.Client client, java.lang.String index, int keepAliveInSeconds, long budget)
void	close()
void	consumeHit(org.elasticsearch.search.SearchHit h)
boolean	hasNext()

Methods inherited from class java.lang.Object

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

Field Detail

id

public final java.lang.String id

Method Detail

allocate

public static Pit allocate(org.elasticsearch.client.Client client,
                           java.lang.String index,
                           int keepAliveInSeconds)

allocateUsingTimebudget

public static Pit allocateUsingTimebudget(org.elasticsearch.client.Client client,
                                          java.lang.String index,
                                          int keepAliveInSeconds,
                                          long budget)

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception

hasNext

public boolean hasNext()

consumeHit

public void consumeHit(org.elasticsearch.search.SearchHit h)

adaptSearch

public void adaptSearch(org.elasticsearch.action.search.SearchRequestBuilder searchBuilder)