Package org.apache.calcite.test
Class StreamTest.OrdersTable
- java.lang.Object
-
- org.apache.calcite.test.StreamTest.BaseOrderStreamTable
-
- org.apache.calcite.test.StreamTest.OrdersTable
-
- All Implemented Interfaces:
org.apache.calcite.schema.ScannableTable
,org.apache.calcite.schema.StreamableTable
,org.apache.calcite.schema.Table
- Enclosing class:
- StreamTest
public static class StreamTest.OrdersTable extends StreamTest.BaseOrderStreamTable implements org.apache.calcite.schema.StreamableTable
Table representing the ORDERS stream.
-
-
Field Summary
Fields Modifier and Type Field Description private com.google.common.collect.ImmutableList<java.lang.Object[]>
rows
-
Fields inherited from class org.apache.calcite.test.StreamTest.BaseOrderStreamTable
protoRowType
-
-
Constructor Summary
Constructors Constructor Description OrdersTable(com.google.common.collect.ImmutableList<java.lang.Object[]> rows)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
isRolledUp(java.lang.String column)
boolean
rolledUpColumnValidInsideAgg(java.lang.String column, org.apache.calcite.sql.SqlCall call, org.apache.calcite.sql.SqlNode parent, org.apache.calcite.config.CalciteConnectionConfig config)
org.apache.calcite.linq4j.Enumerable<java.lang.Object[]>
scan(org.apache.calcite.DataContext root)
org.apache.calcite.schema.Table
stream()
-
Methods inherited from class org.apache.calcite.test.StreamTest.BaseOrderStreamTable
getJdbcTableType, getRowType, getStatistic
-
-
-
-
Method Detail
-
scan
public org.apache.calcite.linq4j.Enumerable<java.lang.Object[]> scan(org.apache.calcite.DataContext root)
- Specified by:
scan
in interfaceorg.apache.calcite.schema.ScannableTable
-
stream
public org.apache.calcite.schema.Table stream()
- Specified by:
stream
in interfaceorg.apache.calcite.schema.StreamableTable
-
isRolledUp
public boolean isRolledUp(java.lang.String column)
- Specified by:
isRolledUp
in interfaceorg.apache.calcite.schema.Table
- Overrides:
isRolledUp
in classStreamTest.BaseOrderStreamTable
-
rolledUpColumnValidInsideAgg
public boolean rolledUpColumnValidInsideAgg(java.lang.String column, org.apache.calcite.sql.SqlCall call, org.apache.calcite.sql.SqlNode parent, org.apache.calcite.config.CalciteConnectionConfig config)
- Specified by:
rolledUpColumnValidInsideAgg
in interfaceorg.apache.calcite.schema.Table
- Overrides:
rolledUpColumnValidInsideAgg
in classStreamTest.BaseOrderStreamTable
-
-