Package org.apache.storm.sql.calcite

Interface ParallelStreamableTable

  • All Superinterfaces:
    StormStreamableTable, org.apache.calcite.schema.StreamableTable, org.apache.calcite.schema.Table
    public interface ParallelStreamableTable
extends StormStreamableTable
    Table that can be converted to a stream. This table also has its parallelism information.
    See Also:
    Delta

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      Integer parallelismHint()
      Returns parallelism hint of this table.

      • Methods inherited from interface org.apache.calcite.schema.StreamableTable

        stream

      • Methods inherited from interface org.apache.calcite.schema.Table

        getJdbcTableType, getRowType, getStatistic, isRolledUp, rolledUpColumnValidInsideAgg

    • Method Detail

      • parallelismHint

        Integer parallelismHint()
        Returns parallelism hint of this table. Returns null if don't know.