org.apache.streams.elasticsearch

Class ElasticsearchQuery

java.lang.Object

org.apache.streams.elasticsearch.ElasticsearchQuery

All Implemented Interfaces:

Serializable, Iterable<org.elasticsearch.search.SearchHit>, Iterator<org.elasticsearch.search.SearchHit>

public class ElasticsearchQuery
extends Object
implements Iterable<org.elasticsearch.search.SearchHit>, Iterator<org.elasticsearch.search.SearchHit>, Serializable

Helper for building, querying, and paging an elasticsearch query.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ElasticsearchQuery() ElasticsearchQuery constructor - resolves ElasticsearchReaderConfiguration from JVM 'elasticsearch'.
ElasticsearchQuery(ElasticsearchReaderConfiguration config) ElasticsearchQuery constructor - uses provided ElasticsearchReaderConfiguration.

Method Summary

Modifier and Type	Method and Description
void	calcNext() shift to next page of scroll.
void	cleanUp()
void	execute(Object obj) execute ElasticsearchQuery.
long	getHitCount()
long	getReadCount()
double	getReadPercent()
long	getRemainingCount()
boolean	hasNext()
protected boolean	hasRecords()
protected boolean	isCompleted()
Iterator<org.elasticsearch.search.SearchHit>	iterator()
org.elasticsearch.search.SearchHit	next()
void	remove()
void	setBatchSize(int batchSize)
void	setQueryBuilder(org.elasticsearch.index.query.QueryBuilder queryBuilder)
void	setScrollTimeout(String scrollTimeout)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

ElasticsearchQuery

public ElasticsearchQuery()

ElasticsearchQuery constructor - resolves ElasticsearchReaderConfiguration from JVM 'elasticsearch'.

ElasticsearchQuery

public ElasticsearchQuery(ElasticsearchReaderConfiguration config)

ElasticsearchQuery constructor - uses provided ElasticsearchReaderConfiguration.

Method Detail

getHitCount

public long getHitCount()

getReadCount

public long getReadCount()

getReadPercent

public double getReadPercent()

getRemainingCount

public long getRemainingCount()

setBatchSize

public void setBatchSize(int batchSize)

setScrollTimeout

public void setScrollTimeout(String scrollTimeout)

setQueryBuilder

public void setQueryBuilder(org.elasticsearch.index.query.QueryBuilder queryBuilder)

execute

public void execute(Object obj)

execute ElasticsearchQuery.

Parameters:

obj - deprecated

iterator

public Iterator<org.elasticsearch.search.SearchHit> iterator()

Specified by:

iterator in interface Iterable<org.elasticsearch.search.SearchHit>

next

public org.elasticsearch.search.SearchHit next()

Specified by:

next in interface Iterator<org.elasticsearch.search.SearchHit>

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<org.elasticsearch.search.SearchHit>

calcNext

public void calcNext()

shift to next page of scroll.

remove

public void remove()

Specified by:

remove in interface Iterator<org.elasticsearch.search.SearchHit>

cleanUp

public void cleanUp()

isCompleted

protected boolean isCompleted()

hasRecords

protected boolean hasRecords()