Class 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.
    • Constructor Detail

      • InfiniteOrdersTable

        public InfiniteOrdersTable()
    • Method Detail

      • scan

        public org.apache.calcite.linq4j.Enumerable<java.lang.Object[]> scan​(org.apache.calcite.DataContext root)
        Specified by:
        scan in interface org.apache.calcite.schema.ScannableTable
      • stream

        public org.apache.calcite.schema.Table stream()
        Specified by:
        stream in interface org.apache.calcite.schema.StreamableTable