Package 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<org.apache.metamodel.data.Row>, org.apache.metamodel.data.DataSet

public abstract class AbstractElasticSearchDataSet
extends org.apache.metamodel.data.AbstractDataSet

DataSet implementation for ElasticSearch

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
protected abstract void	closeNow()
protected void	finalize()
org.apache.metamodel.data.Row	getRow()
boolean	next()
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<org.apache.metamodel.query.SelectItem> selectItems)

Method Detail

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.apache.metamodel.data.DataSet

Overrides:

close in class org.apache.metamodel.data.AbstractDataSet

closeNow

protected abstract void closeNow()

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

next

public boolean next()

scrollSearchResponse

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

Throws:

IOException

getRow

public org.apache.metamodel.data.Row getRow()