Class InfiniteOrdersStreamTableFactory

java.lang.Object
org.apache.calcite.test.schemata.orderstream.InfiniteOrdersStreamTableFactory
All Implemented Interfaces:
TableFactory<Table>

public class InfiniteOrdersStreamTableFactory extends Object implements TableFactory<Table>
Mock table that returns a stream of orders from a fixed array.
  • Constructor Details

    • InfiniteOrdersStreamTableFactory

      public InfiniteOrdersStreamTableFactory()
  • Method Details

    • create

      public Table create(SchemaPlus schema, String name, Map<String,Object> operand, @Nullable RelDataType rowType)
      Description copied from interface: TableFactory
      Creates a Table.
      Specified by:
      create in interface TableFactory<Table>
      Parameters:
      schema - Schema this table belongs to
      name - Name of this table
      operand - The "operand" JSON property
      rowType - Row type. Specified if the "columns" JSON property.
      Returns:
      created table