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 and 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 Detail

parallelismHint

Integer parallelismHint()

Returns parallelism hint of this table. Returns null if don’t know.