[ 
https://issues.apache.org/jira/browse/BEAM-14036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17549840#comment-17549840
 ] 

Danny McCormick commented on BEAM-14036:
----------------------------------------

This issue has been migrated to https://github.com/apache/beam/issues/21412

> Convert Pub/Sub Schema IO to SchemaTransform
> --------------------------------------------
>
>                 Key: BEAM-14036
>                 URL: https://issues.apache.org/jira/browse/BEAM-14036
>             Project: Beam
>          Issue Type: Sub-task
>          Components: sdk-java-core
>            Reporter: Lara Schmidt
>            Assignee: Damon Douglas
>            Priority: P2
>          Time Spent: 4h 10m
>  Remaining Estimate: 0h
>
> 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|https://github.com/apache/beam/blob/3c62cc906f487d7cd93430bf35d6ac2cd4cc6d3c/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubSchemaIOProvider.java]
>  to extend 
> [TypedSchemaTransformProvider|https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/TypedSchemaTransformProvider.java].
> This task will be separated into *+four+* PRs to focus on Read and Write 
> SchemaTransforms and their respective Configurations.  See 
> [BigQuerySchemaTransformReadProvider|https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySchemaTransformReadProvider.java]
>  and 
> [BigQuerySchemaTransformWriteConfiguration|https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySchemaTransformWriteConfiguration.java]
>  as an example design pattern.



--
This message was sent by Atlassian Jira
(v8.20.7#820007)

Reply via email to