Class HrClusteredSchema.PkClusteredTable

  • All Implemented Interfaces:
    org.apache.calcite.schema.ScannableTable, org.apache.calcite.schema.Table, org.apache.calcite.schema.Wrapper
    Enclosing class:
    HrClusteredSchema

    private static class HrClusteredSchema.PkClusteredTable
    extends org.apache.calcite.schema.impl.AbstractTable
    implements org.apache.calcite.schema.ScannableTable
    A table sorted (ascending direction and nulls last) on the primary key.
    • Field Summary

      Fields 
      Modifier and Type Field Description
      private java.util.List<java.lang.Object[]> data  
      private org.apache.calcite.util.ImmutableBitSet pkColumns  
      private java.util.function.Function<org.apache.calcite.rel.type.RelDataTypeFactory,​org.apache.calcite.rel.type.RelDataType> typeBuilder  
    • Constructor Summary

      Constructors 
      Constructor Description
      PkClusteredTable​(java.util.function.Function<org.apache.calcite.rel.type.RelDataTypeFactory,​org.apache.calcite.rel.type.RelDataType> dataTypeBuilder, org.apache.calcite.util.ImmutableBitSet pkColumns, java.util.List<java.lang.Object[]> data)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.calcite.rel.type.RelDataType getRowType​(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)  
      org.apache.calcite.schema.Statistic getStatistic()  
      org.apache.calcite.linq4j.Enumerable<java.lang.Object[]> scan​(org.apache.calcite.DataContext root)  
      • Methods inherited from class org.apache.calcite.schema.impl.AbstractTable

        getJdbcTableType, isRolledUp, rolledUpColumnValidInsideAgg, unwrap
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
      • Methods inherited from interface org.apache.calcite.schema.Table

        getJdbcTableType, isRolledUp, rolledUpColumnValidInsideAgg
    • Field Detail

      • pkColumns

        private final org.apache.calcite.util.ImmutableBitSet pkColumns
      • data

        private final java.util.List<java.lang.Object[]> data
      • typeBuilder

        private final java.util.function.Function<org.apache.calcite.rel.type.RelDataTypeFactory,​org.apache.calcite.rel.type.RelDataType> typeBuilder
    • Constructor Detail

      • PkClusteredTable

        PkClusteredTable​(java.util.function.Function<org.apache.calcite.rel.type.RelDataTypeFactory,​org.apache.calcite.rel.type.RelDataType> dataTypeBuilder,
                         org.apache.calcite.util.ImmutableBitSet pkColumns,
                         java.util.List<java.lang.Object[]> data)
    • Method Detail

      • getStatistic

        public org.apache.calcite.schema.Statistic getStatistic()
        Specified by:
        getStatistic in interface org.apache.calcite.schema.Table
        Overrides:
        getStatistic in class org.apache.calcite.schema.impl.AbstractTable
      • getRowType

        public org.apache.calcite.rel.type.RelDataType getRowType​(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
        Specified by:
        getRowType in interface org.apache.calcite.schema.Table
      • 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