[ https://issues.apache.org/jira/browse/BEAM-9208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Brian Hulette updated BEAM-9208: -------------------------------- Labels: (was: stale-P2) > Add support for mapping columns to pubsub message attributes in flat schemas > DDL > -------------------------------------------------------------------------------- > > Key: BEAM-9208 > URL: https://issues.apache.org/jira/browse/BEAM-9208 > Project: Beam > Issue Type: Improvement > Components: dsl-sql > Reporter: Brian Hulette > Priority: P2 > > Context: > https://lists.apache.org/thread.html/bf4c37f21bda194d7f8c40f6e7b9a776262415755cc1658412af3c76%40%3Cdev.beam.apache.org%3E > The syntax should look something like this (proposed by [~alexvanboxel]): > {code} > CREATE TABLE people ( > my_timestamp TIMESTAMP *OPTION(ref="pubsub:event_timestamp)*, > my_id VARCHAR *OPTION(ref="pubsub:attributes['id_name']")*, > name VARCHAR, > age INTEGER > ) > TYPE 'pubsub' > LOCATION 'projects/my-project/topics/my-topic' > {code} > This jira pertains specifically to the my_id field in this example. -- This message was sent by Atlassian Jira (v8.3.4#803005)