Package org.apache.calcite.test
Class StreamTest.BaseOrderStreamTable
- java.lang.Object
-
- org.apache.calcite.test.StreamTest.BaseOrderStreamTable
-
- All Implemented Interfaces:
org.apache.calcite.schema.ScannableTable
,org.apache.calcite.schema.Table
- Direct Known Subclasses:
StreamTest.InfiniteOrdersTable
,StreamTest.OrdersHistoryTable
,StreamTest.OrdersTable
- Enclosing class:
- StreamTest
private abstract static class StreamTest.BaseOrderStreamTable extends java.lang.Object implements org.apache.calcite.schema.ScannableTable
Base table for the Orders table. Manages the base schema used for the test tables and common functions.
-
-
Field Summary
Fields Modifier and Type Field Description protected org.apache.calcite.rel.type.RelProtoDataType
protoRowType
-
Constructor Summary
Constructors Modifier Constructor Description private
BaseOrderStreamTable()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.calcite.schema.Schema.TableType
getJdbcTableType()
org.apache.calcite.rel.type.RelDataType
getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
org.apache.calcite.schema.Statistic
getStatistic()
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)
-
-
-
Method Detail
-
getRowType
public org.apache.calcite.rel.type.RelDataType getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
- Specified by:
getRowType
in interfaceorg.apache.calcite.schema.Table
-
getStatistic
public org.apache.calcite.schema.Statistic getStatistic()
- Specified by:
getStatistic
in interfaceorg.apache.calcite.schema.Table
-
getJdbcTableType
public org.apache.calcite.schema.Schema.TableType getJdbcTableType()
- Specified by:
getJdbcTableType
in interfaceorg.apache.calcite.schema.Table
-
isRolledUp
public boolean isRolledUp(java.lang.String column)
- Specified by:
isRolledUp
in interfaceorg.apache.calcite.schema.Table
-
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
-
-