ahmedabu98 commented on code in PR #30910:
URL: https://github.com/apache/beam/pull/30910#discussion_r1568193684
##########
sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/Managed.java:
##########
@@ -108,8 +107,8 @@ public static ManagedTransform read(String source) {
}
/**
- * Instantiates a {@link Managed.Write} transform for the specified sink.
The supported managed
- * sinks are:
+ * Instantiates a {@link Managed.ManagedTransform} transform for the
specified sink. The supported
Review Comment:
Can `ManagedTransform` take on that role? It extends SchemaTransform (ie.
PTransform<PCollectionRowTuple, PCollectionRowTuple>) but we can change that to
`PCollectionTuple` to include generic types in the future. Within, it can do
whatever conversions necessary.
--
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]
