Package org.apache.calcite.adapter.elasticsearch

Class ScrollingTest

java.lang.Object

org.apache.calcite.adapter.elasticsearch.ScrollingTest

public class ScrollingTest
extends java.lang.Object

Tests usage of scrolling API like correct results and resource cleanup (delete scroll after scan).

Field Summary

Fields

Modifier and Type	Field	Description
private static java.lang.String	NAME
static EmbeddedElasticsearchPolicy	NODE
private static int	SIZE

Constructor Summary

Constructors

Constructor	Description
ScrollingTest()

Method Summary

Modifier and Type	Method	Description
private void	assertNoActiveScrolls()	Ensures there are no pending scroll contexts in elastic search cluster.
private CalciteAssert.ConnectionFactory	newConnectionFactory(int fetchSize)
void	scrolling()
static void	setupInstance()

Methods inherited from class java.lang.Object

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

Field Detail

NODE

public static final EmbeddedElasticsearchPolicy NODE

NAME

private static final java.lang.String NAME

See Also:

Constant Field Values

SIZE

private static final int SIZE

See Also:

Constant Field Values

Constructor Detail

ScrollingTest

public ScrollingTest()

Method Detail

setupInstance

public static void setupInstance()
                          throws java.lang.Exception

Throws:

java.lang.Exception

newConnectionFactory

private CalciteAssert.ConnectionFactory newConnectionFactory(int fetchSize)

scrolling

public void scrolling()
               throws java.lang.Exception

Throws:

java.lang.Exception

assertNoActiveScrolls

private void assertNoActiveScrolls()
                            throws java.io.IOException

Ensures there are no pending scroll contexts in elastic search cluster. Queries /_nodes/stats/indices/search endpoint.

Throws:

java.io.IOException

See Also:

Indices Stats