Class Hierarchy
- java.lang.Object
- org.apache.calcite.adapter.kafka.KafkaMessageEnumerator<K,
V> (implements org.apache.calcite.linq4j.Enumerator<T>) - org.apache.calcite.adapter.kafka.KafkaRowConverterImpl (implements org.apache.calcite.adapter.kafka.KafkaRowConverter<K,
V>) - org.apache.calcite.adapter.kafka.KafkaStreamTable (implements org.apache.calcite.schema.ScannableTable, org.apache.calcite.schema.StreamableTable)
- org.apache.calcite.adapter.kafka.KafkaTableFactory (implements org.apache.calcite.schema.TableFactory<T>)
- org.apache.calcite.adapter.kafka.KafkaTableOptions
- org.apache.calcite.adapter.kafka.KafkaMessageEnumerator<K,
Interface Hierarchy
- org.apache.calcite.adapter.kafka.KafkaRowConverter<K,
V>