org.apache.metamodel.elasticsearch

Class AbstractElasticSearchDataSet

java.lang.Object

org.apache.metamodel.util.BaseObject

org.apache.metamodel.data.AbstractDataSet

org.apache.metamodel.elasticsearch.AbstractElasticSearchDataSet

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<Row>, DataSet

public abstract class AbstractElasticSearchDataSet
extends AbstractDataSet

DataSet implementation for ElasticSearch

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicBoolean	_closed
protected org.elasticsearch.search.SearchHit	_currentHit
protected int	_hitIndex
protected org.elasticsearch.action.search.SearchResponse	_searchResponse

Constructor Summary

Constructors

Constructor and Description
AbstractElasticSearchDataSet(org.elasticsearch.action.search.SearchResponse searchResponse, List<SelectItem> selectItems)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the DataSet and any resources it may be holding.
protected abstract void	closeNow()
protected void	finalize()
Row	getRow()
boolean	next() Moves forward to the next row.
protected abstract org.elasticsearch.action.search.SearchResponse	scrollSearchResponse(String scrollId)

Methods inherited from class org.apache.metamodel.data.AbstractDataSet

decorateIdentity, getHeader, getSelectItems, indexOf, iterator, toObjectArrays, toRows, toString

Methods inherited from class org.apache.metamodel.util.BaseObject

classEquals, equals, hashCode

Methods inherited from class java.lang.Object

clone, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

_closed

protected final AtomicBoolean _closed

_searchResponse

protected org.elasticsearch.action.search.SearchResponse _searchResponse

_currentHit

protected org.elasticsearch.search.SearchHit _currentHit

_hitIndex

protected int _hitIndex

Constructor Detail

AbstractElasticSearchDataSet

public AbstractElasticSearchDataSet(org.elasticsearch.action.search.SearchResponse searchResponse,
                                    List<SelectItem> selectItems)

Method Detail

close

public void close()

Description copied from class: AbstractDataSet

Closes the DataSet and any resources it may be holding.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface DataSet

Overrides:

close in class AbstractDataSet

closeNow

protected abstract void closeNow()

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

next

public boolean next()

Description copied from interface: DataSet

Moves forward to the next row.

Returns:

true if there is a next row or false if not.

scrollSearchResponse

protected abstract org.elasticsearch.action.search.SearchResponse scrollSearchResponse(String scrollId)
                                                                                throws IOException

Throws:

IOException

getRow

public Row getRow()

Returns:

the current row.