pskevin commented on a change in pull request #12445: URL: https://github.com/apache/beam/pull/12445#discussion_r465934590
########## File path: sdks/go/pkg/beam/external.go ########## @@ -16,10 +16,144 @@ package beam import ( + "context" + "fmt" + "github.com/apache/beam/sdks/go/pkg/beam/core/graph" + "github.com/apache/beam/sdks/go/pkg/beam/core/runtime/graphx" "github.com/apache/beam/sdks/go/pkg/beam/internal/errors" + jobpb "github.com/apache/beam/sdks/go/pkg/beam/model/jobmanagement_v1" + pipepb "github.com/apache/beam/sdks/go/pkg/beam/model/pipeline_v1" + "google.golang.org/grpc" ) +// ExternalTransform represents the cross-language transform in and out of the Pipeline as a MultiEdge and Expanded proto respectively +type ExternalTransform struct { Review comment: The current version was never meant to be representative of what the final API would be. Only after discussing code organization was the API surface meant to be refined. Thanks for the new type idea! It'll make separation of concerns much clearer. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org