Skip to content

Convert Pub/Sub Schema IO to SchemaTransform #21412

@damccorm

Description

@damccorm

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.

Imported from Jira BEAM-14036. Original Jira may contain additional context.
Reported by: laraschmidt.
Subtask of issue #21406

Metadata

Metadata

Assignees

Labels

P2coredone & doneIssue has been reviewed after it was closed for verification, followups, etc.javasub-task

Type

No type

Projects

No projects

Relationships

None yet

Development

No branches or pull requests

Issue actions