Package org.apache.calcite.test.schemata.orderstream

Class InfiniteOrdersTable

java.lang.Object

org.apache.calcite.test.schemata.orderstream.BaseOrderStreamTable

org.apache.calcite.test.schemata.orderstream.InfiniteOrdersTable

All Implemented Interfaces:

ScannableTable, StreamableTable, Table

public class InfiniteOrdersTable
extends BaseOrderStreamTable
implements StreamableTable

Table representing an infinitely larger ORDERS stream.

Field Summary

Fields inherited from class org.apache.calcite.test.schemata.orderstream.BaseOrderStreamTable

protoRowType

Constructor Summary

Constructors

Constructor	Description
InfiniteOrdersTable()

Method Summary

Modifier and Type	Method	Description
Enumerable<@Nullable Object[]>	scan(DataContext root)	Returns an enumerator over the rows in this Table.
Table	stream()	Returns an enumerator over the rows in this Table.

Methods inherited from class org.apache.calcite.test.schemata.orderstream.BaseOrderStreamTable

getJdbcTableType, getRowType, getStatistic, isRolledUp, rolledUpColumnValidInsideAgg

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.calcite.schema.Table

getJdbcTableType, getRowType, getStatistic, isRolledUp, rolledUpColumnValidInsideAgg

Constructor Details

InfiniteOrdersTable

public InfiniteOrdersTable()

Method Details

scan

public Enumerable<@Nullable Object[]> scan(DataContext root)

Description copied from interface: ScannableTable

Returns an enumerator over the rows in this Table. Each row is represented as an array of its column values.

Specified by:

scan in interface ScannableTable

stream

public Table stream()

Description copied from interface: StreamableTable

Returns an enumerator over the rows in this Table. Each row is represented as an array of its column values.

Specified by:

stream in interface StreamableTable