ndopj commented on issue #32079: URL: https://github.com/apache/beam/issues/32079#issuecomment-2268705043
Looking at the following code: https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubSchemaIOProvider.java#L103 It seems that current `pubsub` source for `CREATE EXTERNAL TABLE` allows for both reading and writing. Adding subscription location option for `CREATE EXTERNAL TABLE` statement could only allow reading, since subscriptions are not writeable. I don't know whether the current SQL implementation in Apache Beam allows for read-only tables. Introducing this functionality would most likely require replacing current `pubsub` location with following - `pubsub_topic` allows for read and writes. - `pubsub_subscription` allows read only. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
