[BEAM-14036] Convert Pub/Sub Schema IO to SchemaTransform

• Type: Sub-task
• Status: Open
• Priority: P2
• Resolution: Unresolved
• Component/s: sdk-java-core
• Assignee: Damon Douglas
• Reporter: Lara Schmidt
• Created: 02/Mar/22 21:51
• Updated: 04/Jun/22 23:24

Description

The output of this task is to refactor sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubSchemaIOProvider.java to extend TypedSchemaTransformProvider.

This task will be separated into four PRs to focus on Read and Write SchemaTransforms and their respective Configurations. See BigQuerySchemaTransformReadProvider and BigQuerySchemaTransformWriteConfiguration as an example design pattern.

Issue Links

• links to: GitHub Pull Request #17730