Details
-
Improvement
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
Currently rowSchema is defined by extending `KafkaRowConverter` only. Feature in this task would support user-defined row schema when creating a table.
Here's one proposed interface in https://github.com/apache/calcite/pull/1127/files#r283913361
interface KafkaRowConverter { RelDataType rowDataType(); Object[] toRow(ConsumerRecord<K, V> message); }
Attachments
Attachments
Issue Links
- is blocked by
-
CALCITE-2913 Adapter for Apache Kafka
- Closed
- relates to
-
CALCITE-3073 Support to consume from timestamp in KafkaAdapter
- Open