Package org.apache.calcite.adapter.elasticsearch

Class Scrolling.SequentialIterator

java.lang.Object

com.google.common.collect.UnmodifiableIterator<T>

com.google.common.collect.AbstractSequentialIterator<ElasticsearchJson.Result>

org.apache.calcite.adapter.elasticsearch.Scrolling.SequentialIterator

All Implemented Interfaces:

java.util.Iterator<ElasticsearchJson.Result>

Enclosing class:

Scrolling

private static class Scrolling.SequentialIterator
extends com.google.common.collect.AbstractSequentialIterator<ElasticsearchJson.Result>

Iterator which consumes current scrollId until full search result is fetched or limit is reached.

Field Summary

Fields

Modifier and Type	Field	Description
private long	count
private long	limit
private ElasticsearchTransport	transport

Constructor Summary

Constructors

Modifier	Constructor	Description
private	SequentialIterator(ElasticsearchJson.Result first, ElasticsearchTransport transport, long limit)

Method Summary

Modifier and Type	Method	Description
protected ElasticsearchJson.Result	computeNext(ElasticsearchJson.Result previous)

Methods inherited from class com.google.common.collect.AbstractSequentialIterator

hasNext, next

Methods inherited from class com.google.common.collect.UnmodifiableIterator

remove

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Field Detail

transport

private final ElasticsearchTransport transport

limit

private final long limit

count

private long count

Constructor Detail

SequentialIterator

private SequentialIterator(ElasticsearchJson.Result first,
                           ElasticsearchTransport transport,
                           long limit)

Method Detail

computeNext

protected ElasticsearchJson.Result computeNext(ElasticsearchJson.Result previous)

Specified by:

computeNext in class com.google.common.collect.AbstractSequentialIterator<ElasticsearchJson.Result>