Package org.apache.calcite.test

Class StreamTest

java.lang.Object

org.apache.calcite.test.StreamTest

public class StreamTest
extends java.lang.Object

Tests for streaming queries.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	StreamTest.BaseOrderStreamTable	Base table for the Orders table.
static class	StreamTest.InfiniteOrdersStreamTableFactory	Mock table that returns a stream of orders from a fixed array.
static class	StreamTest.InfiniteOrdersTable	Table representing an infinitely larger ORDERS stream.
static class	StreamTest.OrdersHistoryTable	Table representing the history of the ORDERS stream.
static class	StreamTest.OrdersStreamTableFactory	Mock table that returns a stream of orders from a fixed array.
static class	StreamTest.OrdersTable	Table representing the ORDERS stream.
static class	StreamTest.ProductsTable	Table representing the PRODUCTS relation.
static class	StreamTest.ProductsTableFactory	Mocks a simple relation to use for stream joining test.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	INFINITE_STREAM_SCHEMA_NAME
private static java.lang.String	STREAM_JOINS_MODEL
static java.lang.String	STREAM_JOINS_SCHEMA_NAME
static java.lang.String	STREAM_MODEL
static java.lang.String	STREAM_SCHEMA_NAME

Constructor Summary

Constructors

Constructor	Description
StreamTest()

Method Summary

Modifier and Type	Method	Description
private static java.lang.String	schemaFor(java.lang.String name, java.lang.Class<? extends org.apache.calcite.schema.TableFactory> clazz)
private java.util.function.Consumer<java.sql.ResultSet>	startsWith(java.lang.String... rows)
void	testInfiniteStreamsDoNotBufferInMemory()	Test case for [CALCITE-809] TableScan does not support large/infinite scans.
void	testStream()
void	testStreamCancel()
void	testStreamFilterProject()
void	testStreamGroupByHaving()
void	testStreamOrderBy()
void	testStreamToRelationJoin()
void	testStreamUnionAllOrderBy()
void	testTumbleViaOver()

Methods inherited from class java.lang.Object

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

Field Detail

STREAM_SCHEMA_NAME

public static final java.lang.String STREAM_SCHEMA_NAME

See Also:

Constant Field Values

INFINITE_STREAM_SCHEMA_NAME

public static final java.lang.String INFINITE_STREAM_SCHEMA_NAME

See Also:

Constant Field Values

STREAM_JOINS_SCHEMA_NAME

public static final java.lang.String STREAM_JOINS_SCHEMA_NAME

See Also:

Constant Field Values

STREAM_JOINS_MODEL

private static final java.lang.String STREAM_JOINS_MODEL

STREAM_MODEL

public static final java.lang.String STREAM_MODEL

Constructor Detail

StreamTest

public StreamTest()

Method Detail

schemaFor

private static java.lang.String schemaFor(java.lang.String name,
                                          java.lang.Class<? extends org.apache.calcite.schema.TableFactory> clazz)

testStream

public void testStream()

testStreamFilterProject

public void testStreamFilterProject()

testStreamGroupByHaving

public void testStreamGroupByHaving()

testStreamOrderBy

public void testStreamOrderBy()

testStreamUnionAllOrderBy

public void testStreamUnionAllOrderBy()

testInfiniteStreamsDoNotBufferInMemory

public void testInfiniteStreamsDoNotBufferInMemory()

Test case for [CALCITE-809] TableScan does not support large/infinite scans.

testStreamCancel

public void testStreamCancel()

testStreamToRelationJoin

public void testStreamToRelationJoin()

testTumbleViaOver

public void testTumbleViaOver()

startsWith

private java.util.function.Consumer<java.sql.ResultSet> startsWith(java.lang.String... rows)