[
https://issues.apache.org/jira/browse/FLINK-20454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489408#comment-17489408
]
li mo commented on FLINK-20454:
-------------------------------
Hi [~caozhen1937], are you still working on the task? can I take it?
actually I've done some hacks successfully locally so that metadata fields
* ingestion-timestamp
* source.timestamp
* source.database
* source.schema
* source.table
* source.properties
are available to be exposed as read-only ({{{}VIRTUAL{}}}) table columns, when
using Flink in my project.
!image-2022-02-09-17-30-37-910.png|width=480,height=301!
and I'd like to commit and hope these changes to be applied in the follow-up
release version of Flink, so that I'm able to get those metadata fields by
directly using Flink libs in the future.
> Allow to read metadata for debezium-avro-confluent format
> ---------------------------------------------------------
>
> Key: FLINK-20454
> URL: https://issues.apache.org/jira/browse/FLINK-20454
> Project: Flink
> Issue Type: Sub-task
> Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table
> SQL / Ecosystem
> Reporter: Jark Wu
> Assignee: CaoZhen
> Priority: Major
> Labels: auto-unassigned, stale-assigned
> Attachments: image-2022-02-09-17-29-22-551.png,
> image-2022-02-09-17-30-37-910.png
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
