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

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

    Methods inherited from interface org.apache.storm.sql.calcite.StormStreamableTable

    primaryKey

    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 Details

    • parallelismHint

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