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

Class OrdersTable

java.lang.Object

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

org.apache.calcite.test.schemata.orderstream.OrdersTable

All Implemented Interfaces:

ScannableTable, StreamableTable, Table

public class OrdersTable
extends BaseOrderStreamTable
implements StreamableTable

Table representing the ORDERS stream.

Field Summary

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

protoRowType

Constructor Summary

Constructors

Constructor	Description
OrdersTable(com.google.common.collect.ImmutableList<Object[]> rows)

Method Summary

Modifier and Type	Method	Description
boolean	isRolledUp(String column)	Determines whether the given column has been rolled up.
boolean	rolledUpColumnValidInsideAgg(String column, SqlCall call, @Nullable SqlNode parent, @Nullable CalciteConnectionConfig config)	Determines whether the given rolled up column can be used inside the given aggregate function.
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

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

Constructor Details

OrdersTable

public OrdersTable(com.google.common.collect.ImmutableList<Object[]> rows)

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

isRolledUp

public boolean isRolledUp(String column)

Description copied from interface: Table

Determines whether the given column has been rolled up.

Specified by:

isRolledUp in interface Table

Overrides:

isRolledUp in class BaseOrderStreamTable

rolledUpColumnValidInsideAgg

public boolean rolledUpColumnValidInsideAgg(String column,
 SqlCall call,
 @Nullable SqlNode parent,
 @Nullable CalciteConnectionConfig config)

Description copied from interface: Table

Determines whether the given rolled up column can be used inside the given aggregate function. You can assume that isRolledUp(column) is true.

Specified by:

rolledUpColumnValidInsideAgg in interface Table

Overrides:

rolledUpColumnValidInsideAgg in class BaseOrderStreamTable

Parameters:

column - The column name for which isRolledUp is true

call - The aggregate call

parent - Parent node of call in the SqlNode tree

config - Config settings. May be null

Returns:

true iff the given aggregate call is valid