Details
-
Bug
-
Status: Open
-
P3
-
Resolution: Unresolved
-
None
-
None
-
None
Description
Having bytes encoded with an arbitrary coder in TestStream causes complications in a portable implementation. See discussion at https://lists.apache.org/thread.html/r65c3464010372b442365ac38601a0312081ae3dcfb77e7eb64ff811b%40%3Cdev.beam.apache.org%3E
A solution is to have TestStream always produce bytes, and have the public-facing transform be a composite that composes a byte-producing primitive with a decoding step.