Package org.apache.calcite.test
Class StreamTest.InfiniteOrdersTable
- java.lang.Object
-
- org.apache.calcite.test.StreamTest.BaseOrderStreamTable
-
- org.apache.calcite.test.StreamTest.InfiniteOrdersTable
-
- 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.InfiniteOrdersTable extends StreamTest.BaseOrderStreamTable implements org.apache.calcite.schema.StreamableTable
Table representing an infinitely larger ORDERS stream.
-
-
Field Summary
-
Fields inherited from class org.apache.calcite.test.StreamTest.BaseOrderStreamTable
protoRowType
-
-
Constructor Summary
Constructors Constructor Description InfiniteOrdersTable()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description 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, isRolledUp, rolledUpColumnValidInsideAgg
-
-
-
-
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
-
-