kennknowles commented on code in PR #34348:
URL: https://github.com/apache/beam/pull/34348#discussion_r2014784811
##########
sdks/go/pkg/beam/runners/prism/internal/urns/urns.go:
##########
@@ -124,6 +124,7 @@ var (
CoderTimer = cdrUrn(pipepb.StandardCoders_TIMER)
CoderKV = cdrUrn(pipepb.StandardCoders_KV)
+ CoderTuple = "beam:coder:tuple:v1"
Review Comment:
I'm curious why it came up vs "just working" like you'd expect with other
`KV(key, whatever)` objects. The process of submitting portably should result
in a length-prefix coder wrapper if needed so the runner can just pass the
bytes through.
--
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: github-unsubscr...@beam.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
