Package org.apache.calcite.test
Class StreamTest.ProductsTable
- java.lang.Object
-
- org.apache.calcite.test.StreamTest.ProductsTable
-
- All Implemented Interfaces:
org.apache.calcite.schema.ScannableTable
,org.apache.calcite.schema.Table
- Enclosing class:
- StreamTest
public static class StreamTest.ProductsTable extends java.lang.Object implements org.apache.calcite.schema.ScannableTable
Table representing the PRODUCTS relation.
-
-
Field Summary
Fields Modifier and Type Field Description private org.apache.calcite.rel.type.RelProtoDataType
protoRowType
private com.google.common.collect.ImmutableList<java.lang.Object[]>
rows
-
Constructor Summary
Constructors Constructor Description ProductsTable(com.google.common.collect.ImmutableList<java.lang.Object[]> rows)
-
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)
org.apache.calcite.linq4j.Enumerable<java.lang.Object[]>
scan(org.apache.calcite.DataContext root)
-
-
-
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
-
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
-
-