java.lang.Object
org.apache.calcite.test.schemata.orderstream.BaseOrderStreamTable
org.apache.calcite.test.schemata.orderstream.OrdersTable
All Implemented Interfaces:
ScannableTable, StreamableTable, Table

public class OrdersTable extends BaseOrderStreamTable implements StreamableTable
Table representing the ORDERS stream.
  • Constructor Details

    • OrdersTable

      public OrdersTable(com.google.common.collect.ImmutableList<Object[]> rows)
  • Method Details

    • scan

      public Enumerable<@Nullable Object[]> scan(DataContext root)
      Description copied from interface: ScannableTable
      Returns an enumerator over the rows in this Table. Each row is represented as an array of its column values.
      Specified by:
      scan in interface ScannableTable
    • stream

      public Table stream()
      Description copied from interface: StreamableTable
      Returns an enumerator over the rows in this Table. Each row is represented as an array of its column values.
      Specified by:
      stream in interface StreamableTable
    • isRolledUp

      public boolean isRolledUp(String column)
      Description copied from interface: Table
      Determines whether the given column has been rolled up.
      Specified by:
      isRolledUp in interface Table
      Overrides:
      isRolledUp in class BaseOrderStreamTable
    • rolledUpColumnValidInsideAgg

      public boolean rolledUpColumnValidInsideAgg(String column, SqlCall call, @Nullable SqlNode parent, @Nullable CalciteConnectionConfig config)
      Description copied from interface: Table
      Determines whether the given rolled up column can be used inside the given aggregate function. You can assume that isRolledUp(column) is true.
      Specified by:
      rolledUpColumnValidInsideAgg in interface Table
      Overrides:
      rolledUpColumnValidInsideAgg in class BaseOrderStreamTable
      Parameters:
      column - The column name for which isRolledUp is true
      call - The aggregate call
      parent - Parent node of call in the SqlNode tree
      config - Config settings. May be null
      Returns:
      true iff the given aggregate call is valid