Let TestStream primitive always produce bytes.
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 1d 20h
- Merged PRs (30d)
- 196
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.
Imported from Jira [BEAM-12827](https://issues.apache.org/jira/browse/BEAM-12827). Original Jira may contain additional context.
Reported by: robertwb.
Contributor guide
Research direction
Start by locating the TestStream primitive and the public-facing transform, then review how the arbitrary coder is currently applied. Confirm the portable implementation path and the discussion linked in the issue before making changes. Done means the primitive produces bytes while decoding remains in the composite public transform.
Written by the indexing model from the issue text.
Assessment
- Domain
- data-engineering, stream-processing
- Issue type
- Refactor
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Mostly clear
- Newbie friendliness
- 42/100