[ https://issues.apache.org/jira/browse/CALCITE-3080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16858246#comment-16858246 ]
Xu Mingmin commented on CALCITE-3080: ------------------------------------- Ensure the timestamp field in CALCITE-3073 always exist. > support user-specified row schema in KafkaAdapter > ------------------------------------------------- > > Key: CALCITE-3080 > URL: https://issues.apache.org/jira/browse/CALCITE-3080 > Project: Calcite > Issue Type: Improvement > Components: kafka-adapter > Reporter: Xu Mingmin > Assignee: Xu Mingmin > Priority: Major > > 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 > {code} > interface KafkaRowConverter { > RelDataType rowDataType(); > Object[] toRow(ConsumerRecord<K, V> message); > } > {code} > -- This message was sent by Atlassian JIRA (v7.6.3#76005)